Struct RingBuffer 

pub struct RingBuffer { /* private fields */ }

Implementations

impl RingBuffer

pub fn new(capacity: usize) -> Result<Self, RingBufferError>

pub unsafe fn from_ptr( header: *mut RingHeader, slots: *mut Slot, capacity: usize, ) -> Self

Create a ring buffer from raw pointers (for shared memory)

Safety

The caller must ensure:

• header points to a valid RingHeader
• slots points to an array of capacity Slot structures
• Memory is properly aligned

pub fn capacity(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn is_full(&self) -> bool

pub fn len(&self) -> u64

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

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

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

Trait Implementations

impl Drop for RingBuffer

fn drop(&mut self)

Executes the destructor for this type.

impl Send for RingBuffer

impl Sync for RingBuffer