Struct InMemoryStateStore 

pub struct InMemoryStateStore { /* private fields */ }

In-memory token-bucket StateStore: the OPEN single-node implementation. The refill-then-consume critical section is a short, synchronous map update (never held across .await), so std::Mutex is the right choice.

Implementations

impl InMemoryStateStore

pub fn new() -> Self

pub fn with_clock(clock: Arc<dyn Clock>) -> Self

Construct with a custom clock (deterministic tests). The clock lives on the store — time is part of how state advances, so it belongs with atomicity.

pub fn with_clock_and_cap( clock: Arc<dyn Clock>, max_tracked_keys: usize, ) -> Self

pub fn tracked_keys(&self) -> usize

Number of currently tracked keys (tests/metrics). Concrete-only: a count is cheap here but meaningless/expensive for a distributed store, so it is not on the StateStore trait.

Trait Implementations

impl Default for InMemoryStateStore

fn default() -> Self

Returns the “default value” for a type.

impl StateStore for InMemoryStateStore

fn try_acquire(&self, key: &str, cost: f64, params: BucketParams) -> Acquired

Atomically refill key’s bucket for the elapsed time, then try to take cost tokens. Allowed iff at least cost tokens are available.