Struct ConcurrentRingBuffer 

pub struct ConcurrentRingBuffer<T>
where
    T: Clone + Send + 'static,
{ /* private fields */ }

Thread-safe wrapper for RingBuffer

Implementations

impl<T> ConcurrentRingBuffer<T>

where T: Clone + Send + 'static,

pub fn new(capacity: usize) -> ConcurrentRingBuffer<T>

Create a new concurrent ring buffer

pub fn push(&self, item: T) -> bool

Push an item (returns true if not dropped, false if dropped due to full)

pub fn pop(&self) -> Option<T>

Pop an item

pub fn len(&self) -> usize

Get current length

pub fn capacity(&self) -> usize

Get capacity

pub fn metrics(&self) -> Arc<RingBufferMetrics>

Get metrics

pub fn clone_ref(&self) -> ConcurrentRingBuffer<T>

Cloneable reference