Struct BatchWriter 

pub struct BatchWriter { /* private fields */ }

Async batch writer that buffers telemetry items and flushes them to the underlying store in batches.

Items are added to an in-memory buffer on submit. A background task periodically flushes the buffer to the store. Call flush() for immediate persistence, or shutdown() to drain all remaining items before process exit.

Implementations

impl BatchWriter

pub fn new(store: Arc<dyn TraceStore>) -> Self

Create a new batch writer with default configuration.

Starts a background flush task that runs until shutdown() is called.

pub fn with_config( store: Arc<dyn TraceStore>, batch_size: usize, flush_interval_ms: u64, ) -> Self

Create a batch writer with custom batch size and flush interval.

pub fn with_config_and_langfuse( store: Arc<dyn TraceStore>, langfuse: Option<LangfuseExporter>, batch_size: usize, flush_interval_ms: u64, ) -> Self

Create a batch writer with optional Langfuse cloud export.

pub async fn submit(&self, item: TelemetryItem) -> Result<(), StoreError>

Submit a telemetry item for async writing.

The item is added to an in-memory buffer. The buffer is flushed to the store either when it reaches batch_size or on the next periodic flush tick.

Errors

Returns StoreError::Storage if the store write fails (only when batch size is exceeded and an immediate flush is triggered).

pub async fn submit_trace(&self, trace: Trace) -> Result<(), StoreError>

Submit a trace for async writing.

Errors

Returns StoreError::Storage if the store write fails.

pub async fn submit_observation( &self, observation: Observation, ) -> Result<(), StoreError>

Submit an observation for async writing.

Errors

Returns StoreError::Storage if the store write fails.

pub async fn submit_session(&self, session: Session) -> Result<(), StoreError>

Submit a session for async writing.

Errors

Returns StoreError::Storage if the store write fails.

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

Flush all buffered items to the store immediately.

Drains the buffer and writes all items to the store. This guarantees all previously submitted items are persisted.

Errors

Returns StoreError::Storage if any write fails.

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

Shutdown the writer, flushing all remaining items.

Signals the background task to stop, then flushes any items still in the buffer.

Errors

Returns StoreError::Storage if any write fails.

Trait Implementations

impl Clone for BatchWriter

fn clone(&self) -> BatchWriter

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for BatchWriter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.