Struct ConcurrentRingBuffer 

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

Thread-safe wrapper for RingBuffer

Implementations

impl<T: Clone + Send + 'static> ConcurrentRingBuffer<T>

pub fn new(capacity: usize) -> Self

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) -> Self

Cloneable reference