trinity.buffer.storage.file module

trinity.buffer.storage.file module#

File Storage

class trinity.buffer.storage.file.FileStorage(config: StorageConfig)[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__(config: StorageConfig) → None[source]#
classmethod get_wrapper(config: StorageConfig)[source]#
write(data: List) → None[source]#
read() → List[source]#
acquire() → int[source]#
release() → int[source]#
Contents