Struct SharedTreiberStack 

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

Implementations

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

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

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

pub fn capacity(&self) -> usize

pub fn push(&self, value: T) -> Result<(), StackError>

Push a value onto the stack.

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

Pop a value off the stack. Returns None if empty.

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

Peek at the top without popping. Returns None if empty.

pub fn is_empty(&self) -> bool

True when the stack is empty.

pub fn approx_len(&self) -> usize

Approximate len: walks the linked list from head. O(N). Subject to race with concurrent push/pop.

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

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

Trait Implementations

impl<T: Copy + Send + Sync + 'static> AdaptiveInstance for SharedTreiberStack<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 SharedTreiberStack<T>

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