trinity.buffer.writer

Submodules

trinity.buffer.writer.queue_writer module

Writer of the Queue buffer.

class trinity.buffer.writer.queue_writer.QueueWriter(meta: StorageConfig, config: BufferConfig)[source]

Bases: BufferWriter

Writer of the Queue buffer.

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

write(data: List) → None[source]: Write to buffer.

finish()[source]: Finish writing.

trinity.buffer.writer.sql_writer module

Writer of the SQL buffer.

class trinity.buffer.writer.sql_writer.SQLWriter(meta: StorageConfig, config: BufferConfig)[source]

Bases: BufferWriter

Writer of the SQL buffer.

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

write(data: list) → None[source]: Write to buffer.

finish() → None[source]: Finish writing.

Module contents