Skip to main content

Module buffered

Module buffered 

Source
Expand description

Generic buffered batch writer for runtime side-effect queues.

This module owns the product-neutral mechanics behind a common Aster pattern: accept records quickly, flush when a batch threshold is reached, flush a partial batch after a short delay, and fall back to a direct write when the in-memory queue is full. Products still own the record type, persistence calls, error mapping, and any audit or metrics semantics.

Structsยง

BufferedBatchConfig
Runtime buffering policy for BufferedBatchWriter.
BufferedBatchWriter
Generic asynchronous batch writer with threshold, delayed, and overflow flushing.