Struct PriorityRingBuffer 

pub struct PriorityRingBuffer { /* private fields */ }

Implementations

impl PriorityRingBuffer

pub fn new(total_slots: usize) -> Result<PriorityRingBuffer, RingBufferError>

pub fn total_slots(&self) -> usize

pub fn slot_counts(&self) -> (usize, usize, usize)

pub fn pending_counts(&self) -> (u64, u64, u64)

pub fn total_pending(&self) -> u64

pub fn is_empty(&self) -> bool

pub fn write( &self, priority: Priority, data: &[u8], ) -> Result<SlotId, RingBufferError>

pub fn read(&self) -> Option<(Priority, Vec<u8>)>

pub fn clear(&self)