Struct SharedVec 

pub struct SharedVec<T: Copy + 'static> { /* private fields */ }

Implementations

impl<T: Copy + 'static> SharedVec<T>

pub fn create(path: impl AsRef<Path>, capacity: usize) -> Result<Self, VecError>

pub fn open( path: impl AsRef<Path>, expected_capacity: usize, ) -> Result<Self, VecError>

pub fn capacity(&self) -> usize

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn push_back(&self, v: T) -> Result<usize, VecError>

Append a value. Returns the index it landed at. Returns Err(Full) when the vec is at capacity.

pub fn pop_back(&self) -> Option<T>

Remove and return the last element. Returns None when empty.

pub fn get(&self, i: usize) -> Option<T>

Read the value at index i. Returns None when i >= len.

pub fn set(&self, i: usize, v: T) -> Result<(), VecError>

Overwrite the value at index i. Returns Err(OutOfBounds) when i >= len.

pub fn clear(&self)

Clear the vec by resetting len to 0. Slot payloads are not zeroed; they become unreachable through bounded indexing.

pub fn snapshot(&self) -> Vec<T>

Snapshot all current values into a Vec. Best-effort: under concurrent writers, the snapshot is a consistent prefix at the moment of the len load, with each slot read under its own SeqLock.

pub fn flush(&self) -> Result<(), VecError>

pub fn flush_async(&self) -> Result<(), VecError>

Non-blocking flush: schedules a writeback via the OS. Note: Windows is only partially async (sync to page cache, not to disk).

Trait Implementations

impl<T: Copy + Send + Sync + 'static> AdaptiveInstance for SharedVec<T>

fn header(&self) -> &HandshakeHeader

fn ring(&self) -> &ObservationRing

fn make_policy(&self) -> Box<dyn Policy>

fn apply_migration(&self, new_tag: u32)

Called by the sidecar when the policy returns a new strategy tag. Default implementation: just set the tag on the header. Primitives that need heavier migration (data-layout swap) override this to perform the swap before (or after) updating the tag.

impl<T: Copy + Send + 'static> Send for SharedVec<T>

impl<T: Copy + Sync + 'static> Sync for SharedVec<T>