trinity.buffer.storage.file module

trinity.buffer.storage.file module#

File Storage

class trinity.buffer.storage.file.FileStorage(storage_config: StorageConfig, config: BufferConfig)[source]#

Bases: object

A wrapper of a local jsonl file.

If wrap_in_ray in StorageConfig is True, this class will be run as a Ray Actor, and provide a remote interface to the local file.

This wrapper is only for writing, if you want to read from the file, use StorageType.QUEUE instead.

__init__(storage_config: StorageConfig, config: BufferConfig) → None[source]#
classmethod get_wrapper(storage_config: StorageConfig, config: BufferConfig)[source]#
write(data: List) → None[source]#
read() → List[source]#
acquire() → int[source]#
release() → int[source]#
Contents