trinity.buffer.writer.file_writer module

Contents

trinity.buffer.writer.file_writer module#

class trinity.buffer.writer.file_writer.JSONWriter(meta: StorageConfig, config: BufferConfig)[source]#

Bases: BufferWriter

__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