Struct InMemorySessionKv 

pub struct InMemorySessionKv { /* private fields */ }

Bounded in-memory store.

The optional shared_bytes counter is where a server-wide KV budget across live sessions attaches: the per-session and aggregate reservations are taken together and both unwound if either fails.

Implementations

impl InMemorySessionKv

pub fn new(limits: SessionKvLimits) -> Self

pub fn with_shared_budget( limits: SessionKvLimits, budget: SharedKvBudget, ) -> Self

pub fn used_bytes(&self) -> u64

Retained bytes: payloads plus keys plus per-entry overhead.

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

Trait Implementations

impl Default for InMemorySessionKv

fn default() -> Self

Returns the “default value” for a type.

impl Drop for InMemorySessionKv

Releasing on drop is what makes the aggregate budget usable for session lifetime: a session ends by having its store dropped, not by removing every key first, so without this the reservation of every ended session would be held forever and the budget would ratchet to its cap.

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl SessionKvStore for InMemorySessionKv

fn get(&self, key: &[u16]) -> Result<Option<Vec<u16>>, SessionKvError>

Ok(None) is an absent key. A present entry holding a serialized null returns Ok(Some(..)) — callers distinguish the two.

fn has(&self, key: &[u16]) -> Result<bool, SessionKvError>

fn set(&self, key: &[u16], payload: &[u16]) -> Result<(), SessionKvError>

fn remove(&self, key: &[u16]) -> Result<bool, SessionKvError>

Ok(true) when an entry existed and was removed.

fn scan( &self, after: Option<&[u16]>, prefix: &[u16], max_scan: usize, ) -> Result<SessionKvPage, SessionKvError>

Keys in UTF-16 code-unit order, strictly after after when given and starting with prefix. Scans at most max_scan keys; matching is exact code units, with no normalization or path semantics.

fn limits(&self) -> SessionKvLimits