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