trinity.buffer.reader

Submodules

trinity.buffer.reader.file_reader module

Filed based buffer reader.

class trinity.buffer.reader.file_reader.SFTDataReader(meta: StorageConfig, config: BufferConfig)[source]

Bases: BufferReader

Reader for SFT file data.

__init__(meta: StorageConfig, config: BufferConfig)[source]

read(strategy: ReadStrategy | None = None) → List[source]: Read from buffer.

class trinity.buffer.reader.file_reader.DPODataReader(meta: StorageConfig, config: BufferConfig)[source]

Bases: BufferReader

__init__(meta: StorageConfig, config: BufferConfig)[source]

read(strategy: ReadStrategy | None = None) → List[source]: Read from buffer.

class trinity.buffer.reader.file_reader.RolloutDataReader(meta: StorageConfig, config: BufferConfig)[source]

Bases: BufferReader

__init__(meta: StorageConfig, config: BufferConfig)[source]

read(strategy: ReadStrategy | None = None)[source]: Read from buffer.

trinity.buffer.reader.queue_reader module

Reader of the Queue buffer.

class trinity.buffer.reader.queue_reader.QueueReader(meta: StorageConfig, config: BufferConfig)[source]

Bases: BufferReader

Reader of the Queue buffer.

__init__(meta: StorageConfig, config: BufferConfig)[source]

read(strategy: ReadStrategy | None = None) → List[source]: Read from buffer.

trinity.buffer.reader.sql_reader module

Reader of the SQL buffer.

class trinity.buffer.reader.sql_reader.SQLReader(meta: StorageConfig, config: BufferConfig)[source]

Bases: BufferReader

Reader of the SQL buffer.

__init__(meta: StorageConfig, config: BufferConfig) → None[source]

read(strategy: ReadStrategy | None = None) → List[source]: Read from buffer.

Module contents