Struct RingSource 

pub struct RingSource<const SLOTS: usize, const SLOT: usize> { /* private fields */ }

A fixed-capacity ring of byte frames over a stack arena — the zero-copy *DK source (DPDK mbuf ring / NVMe CQ view / per-core telemetry ring). Items lent to the visitor borrow directly into arena; no heap, no copy on the read.

Implementations

impl<const SLOTS: usize, const SLOT: usize> RingSource<SLOTS, SLOT>

pub const fn new() -> Self

pub fn push(&mut self, frame: &[u8]) -> bool

Copy one frame into the next slot. false if full or oversized (the producer’s concern — the ring never allocates).

pub fn close(&mut self)

No more frames will arrive — the next fully-drained pass returns DrainState::Drained.

Trait Implementations

impl<const SLOTS: usize, const SLOT: usize> Default for RingSource<SLOTS, SLOT>

fn default() -> Self

Returns the “default value” for a type.

impl<const SLOTS: usize, const SLOT: usize> DrainSource for RingSource<SLOTS, SLOT>

type Item = [u8]

The item lent to the visitor. ?Sized so it can be a [u8] slot view.

fn drain_ready( &mut self, visitor: &mut dyn FnMut(&[u8]) -> ControlFlow<()>, ) -> DrainState

Drain all currently-ready items, calling visitor on each (borrowed) item in order. No alloc, no syscall, no waker on the hot path.