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.