reductstore_agent.writer.base module

Base interface for output writers.

class reductstore_agent.writer.base.OutputWriter

Bases: ABC

Abstract base class for output writers providing unified interface.

abstractmethod async flush_and_upload_batch()

Flush and upload any pending data.

register_message_schema(topic_name: str, msg_type_str: str)

Register schema for a topic and message type.

abstract property size: int

Get current buffer/batch size.

abstractmethod write_message(message: Any, publish_time: int, topic: str, **kwargs)

Write message to output.