Struct Producer 

pub struct Producer<T> { /* private fields */ }

The producer half of the ring buffer.

Lives on the Control Plane (Tokio). It is Send so it can be moved between Tokio worker threads.

Implementations

impl<T> Producer<T>

pub fn try_push(&mut self, value: T) -> Result<()>

Try to enqueue a value. Returns Err(BridgeError::Full) if the ring is full, or Err(BridgeError::Disconnected) if the consumer was dropped.

pub fn utilization(&self) -> u8

Returns the current queue utilization as a percentage (0-100).

pub fn len(&self) -> usize

Returns the number of items currently in the queue.

pub fn is_empty(&self) -> bool

Returns true if the queue is empty.

pub fn capacity(&self) -> usize

Returns the fixed capacity of the ring buffer.

pub fn metrics(&self) -> &BridgeMetrics

Returns a reference to the shared metrics.

Trait Implementations

impl<T> Drop for Producer<T>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.