Struct KvRing 

pub struct KvRing { /* private fields */ }

Implementations

impl KvRing

pub fn new(rows: usize, window: usize) -> KvRing

pub fn rows(&self) -> usize

pub fn base(&self) -> usize

pub fn window(&self) -> usize

pub fn append_plan( &self, len: usize, retain_from: usize, append_rows: usize, ) -> Result<KvRingAppend, String>

Plan a contiguous physical append. When the tail would wrap, retain the caller’s exact aligned read prefix at row zero; the following read remains one contiguous CUDA view.

pub fn apply_rebase(&mut self, new_base: usize)

pub fn physical_range( &self, start: usize, end: usize, ) -> Result<Range<usize>, String>

pub fn can_rewind_to(&self, len: usize) -> bool

A rewind is usable only when the next aligned Step35 window view is still resident.

pub fn restore_plan(&self, len: usize) -> Result<(usize, Range<usize>), String>

Plan a checkpoint restore into a FRESH ring (base 0): the aligned live window ending at absolute len, as (new_base, source physical rows). len is the ABSOLUTE stream length the checkpoint recorded — for a lapped ring it exceeds the physical row count, so a restore that copies len rows from row zero is an out-of-bounds device slice (the 2026-08-29 warm-turn-at-40k GPU-worker panic). Refuses when this ring no longer holds the window (checkpoint lapped: the caller must full re-prime).

Trait Implementations

impl Clone for KvRing

fn clone(&self) -> KvRing

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for KvRing

impl Debug for KvRing

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

Formats the value using the given formatter.

impl Eq for KvRing

impl PartialEq for KvRing

fn eq(&self, other: &KvRing) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for KvRing