trinity.buffer.writer

Submodules

trinity.buffer.writer.file_writer module

class trinity.buffer.writer.file_writer.JSONWriter(meta: StorageConfig, config: BufferConfig)

Bases: BufferWriter

__init__(meta: StorageConfig, config: BufferConfig)

write(data: List) → None

Write to buffer.

acquire() → int

Acquire the buffer writer.

Returns:

The reference count of the buffer after acquiring.

Return type:

int

release() → int

Release the buffer writer. After release, the buffer writer can not be used again.

Returns:

The reference count of the buffer after releasing.

Return type:

int

trinity.buffer.writer.queue_writer module

Writer of the Queue buffer.

class trinity.buffer.writer.queue_writer.QueueWriter(meta: StorageConfig, config: BufferConfig)

Bases: BufferWriter

Writer of the Queue buffer.

__init__(meta: StorageConfig, config: BufferConfig)

write(data: List) → None

Write to buffer.

acquire() → int

Acquire the buffer writer.

Returns:

The reference count of the buffer after acquiring.

Return type:

int

release() → int

Release the buffer writer. After release, the buffer writer can not be used again.

Returns:

The reference count of the buffer after releasing.

Return type:

int

trinity.buffer.writer.sql_writer module

Writer of the SQL buffer.

class trinity.buffer.writer.sql_writer.SQLWriter(meta: StorageConfig, config: BufferConfig)

Bases: BufferWriter

Writer of the SQL buffer.

__init__(meta: StorageConfig, config: BufferConfig) → None

write(data: list) → None

Write to buffer.

acquire() → int

Acquire the buffer writer.

Returns:

The reference count of the buffer after acquiring.

Return type:

int

release() → int

Release the buffer writer. After release, the buffer writer can not be used again.

Returns:

The reference count of the buffer after releasing.

Return type:

int

Module contents