Struct MsgBatcher 

pub struct MsgBatcher { /* private fields */ }

Implementations

impl MsgBatcher

pub async fn new(database_url: &str) -> Result<Self, BatcherError>

Create new batcher with PostgreSQL connection string

pub fn with_batch_size(self, size: usize) -> Self

Configure batch size (default: 5000)

pub fn with_flush_interval(self, seconds: u64) -> Self

Configure flush interval in seconds (default: 5)

pub fn with_max_buffer(self, size: usize) -> Self

Configure max buffer size (default: 10000)

pub async fn append(&self, msg: Message) -> Result<(), BatcherError>

Append message to buffer (non-blocking, ~microseconds)

pub async fn flush(&self) -> Result<(), BatcherError>

Manually flush all pending messages

pub async fn run_background(&self) -> Result<(), BatcherError>

Background worker - call this in your main function

pub async fn shutdown(&self) -> Result<(), BatcherError>

Stop background worker gracefully

pub async fn buffer_size(&self) -> usize

Get current buffer size