Struct Producer 

pub struct Producer { /* private fields */ }

Implementations

impl Producer

pub fn new(config: ProducerConfig, clock: Arc<dyn Clock>) -> Result<Self>

Create a new buffer from the given configuration and clock.

pub fn with_object_store( config: ProducerConfig, object_store: Arc<dyn ObjectStore>, clock: Arc<dyn Clock>, ) -> Result<Self>

Create a new buffer using a pre-built object store.

This is useful when you need to share an object store instance between a Producer and a Consumer (e.g. in tests).

pub async fn produce( &self, entries: Vec<Bytes>, metadata: Bytes, ) -> Result<WriteHandle>

Submit a set of entries and associated metadata for ingestion.

Returns a WriteHandle that can be used to check or await durability. Applies backpressure when the message buffer is full.

Returns Error::InvalidInput if entries is empty or if metadata exceeds 2³²−1 bytes.

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

Flush the current batch, blocking until all pending entries are durably written.

pub fn conflict_rate(&self) -> f64

Return the fraction of manifest writes that encountered optimistic-concurrency conflicts.

pub async fn close(self) -> Result<()>

Shut down the buffer, flushing any remaining buffered entries before returning.