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.
-
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
