WorkingMemory

Struct WorkingMemory 

Source
pub struct WorkingMemory { /* private fields */ }
Expand description

Working memory - session-scoped KV store with TTL.

TigerStyle:

  • Bounded capacity (~1MB)
  • TTL-based expiration
  • Explicit size tracking
  • DST-compatible via set_clock_ms()

Implementations§

Source§

impl WorkingMemory

Source

pub fn new() -> Self

Create a new working memory with default configuration.

Source

pub fn with_config(config: WorkingMemoryConfig) -> Self

Create a new working memory with custom configuration.

Source

pub fn set_clock_ms(&mut self, ms: u64)

Set the internal clock (for DST).

TigerStyle: Explicit time control for simulation.

Source

pub fn clock_ms(&self) -> u64

Get the internal clock value.

Source

pub fn set( &mut self, key: &str, value: &[u8], ttl_ms: Option<u64>, ) -> Result<(), WorkingMemoryError>

Set an entry with optional TTL.

If TTL is None, uses the default TTL from config. If key already exists, the entry is replaced and TTL is reset.

§Errors

Returns error if entry is too large, memory is full, or too many entries.

Source

pub fn get(&self, key: &str) -> Option<&[u8]>

Get an entry by key.

Returns None if key doesn’t exist or entry is expired.

Source

pub fn delete(&mut self, key: &str) -> bool

Delete an entry by key.

Returns true if entry existed (even if expired), false otherwise.

Source

pub fn exists(&self, key: &str) -> bool

Check if a key exists (and is not expired).

Source

pub fn cleanup_expired(&mut self) -> usize

Remove all expired entries.

Returns the number of entries removed.

Source

pub fn used_bytes(&self) -> usize

Get used bytes (keys + values).

Source

pub fn available_bytes(&self) -> usize

Get available bytes.

Source

pub fn entry_count(&self) -> usize

Get entry count (including expired).

Source

pub fn is_empty(&self) -> bool

Check if empty.

Source

pub fn clear(&mut self)

Clear all entries.

Source

pub fn config(&self) -> &WorkingMemoryConfig

Get configuration.

Trait Implementations§

Source§

impl Debug for WorkingMemory

Source§

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

Formats the value using the given formatter. Read more
Source§

impl Default for WorkingMemory

Source§

fn default() -> Self

Returns the “default value” for a type. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more