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.
-
async write_async(data)[source]
Write to buffer asynchronously.
-
async acquire() → int[source]
Acquire the buffer writer.
- Returns:
The reference count of the buffer after acquiring.
- Return type:
int
-
async release() → int[source]
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
