Struct BufferSender 

pub struct BufferSender { /* private fields */ }

A sender handle to a memory buffer.

Implementations

impl BufferSender

pub async fn send(&self, batch: EventBatch) -> Result<(), SendError<EventBatch>>

Sends a batch to the buffer.

If the buffer is full and when_full is Block, this will await until space is available, propagating backpressure upstream.

pub fn capacity(&self) -> usize

Returns the current number of free slots in the buffer.

pub fn max_capacity(&self) -> usize

Returns the maximum capacity of the buffer.

pub fn utilization(&self) -> f64

Returns the utilization of the buffer as a fraction between 0.0 and 1.0.

pub fn try_send( &self, batch: EventBatch, ) -> Result<(), TrySendError<EventBatch>>

Try to send without blocking. Returns an error if full.

Trait Implementations

impl Clone for BufferSender

fn clone(&self) -> BufferSender

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BufferSender

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

Formats the value using the given formatter.