Struct MCache 

pub struct MCache<const DEPTH: usize> { /* private fields */ }

Implementations

impl<const DEPTH: usize> MCache<DEPTH>

pub fn new() -> Self

Create a ring buffer with a power-of-two number of slots.

pub fn stop(&self)

pub fn is_running(&self) -> bool

pub fn publish(&self, meta: FragmentMetadata)

Publish a fragment’s metadata into the ring.

pub fn wait(&self, seq: u64) -> ReadResult<FragmentMetadata>

Busy-wait for a specific sequence number to appear.

Returns:

• ReadResult::Ok(meta) if the sequence was successfully read
• ReadResult::Overrun if the consumer was lapped by the producer
• ReadResult::NotReady if the mcache was stopped before the sequence appeared

pub fn try_read(&self, seq: u64) -> ReadResult<FragmentMetadata>

Attempt a lock-free read of the metadata at a specific sequence.

Returns:

• ReadResult::Ok(meta) if the sequence was successfully read
• ReadResult::NotReady if the sequence has not been published yet
• ReadResult::Overrun if the consumer was lapped by the producer

Trait Implementations

impl<const DEPTH: usize> Debug for MCache<DEPTH>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<const DEPTH: usize> Default for MCache<DEPTH>

fn default() -> Self

Returns the “default value” for a type.