Struct PersistentEngine 

pub struct PersistentEngine { /* private fields */ }

Persistent-engine handle. Owns the host-side view of the ring buffer. The GPU kernel is a separate concern gated behind the persistent cargo feature.

Implementations

impl PersistentEngine

pub fn new(ring_size: u32) -> Self

Construct an engine with a ring capacity of ring_size slots. Must be a nonzero power of two so index = slot & (cap-1) is correct.

pub fn try_new(ring_size: u32) -> Result<Self, String>

Construct an engine only when the ring capacity already satisfies the persistent-ring indexing contract.

pub fn ring_size(&self) -> u32

Capacity of the ring buffer.

pub fn enqueue(&self, item: PersistentWorkItem) -> Result<u32, QueueFull>

Enqueue a PersistentWorkItem. Returns Ok(slot_index) on success, or Err(QueueFull) if the ring is full. Thread-safe under concurrent producers (lock-free CAS on head).

pub fn claim(&self) -> Option<PersistentWorkItem>

Consumer-side claim. Returns the next available item or None if the queue is empty. Thread-safe under concurrent consumers.

pub fn mark_done(&self, slot_idx: u32) -> Result<(), String>

Mark item at slot_idx as done.

pub fn is_done(&self, slot_idx: u32) -> Result<bool, String>

Whether the consumer finished the item at slot_idx.

pub fn try_in_flight(&self) -> Result<u32, String>

Number of items queued and pending claim.

pub fn in_flight(&self) -> u32

Number of items queued and pending claim.

pub fn head_counter(&self) -> u64

Monotonic head counter (modulo ring_size = slot index).

pub fn head(&self) -> u32

Monotonic head counter exposed through the legacy u32 API.

pub fn tail_counter(&self) -> u64

Monotonic tail counter.

pub fn tail(&self) -> u32

Monotonic tail counter exposed through the legacy u32 API.

Trait Implementations

impl Debug for PersistentEngine

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

Formats the value using the given formatter.