Struct RedbBackend 

pub struct RedbBackend { /* private fields */ }

redb-backed durable state. Atomicity comes from redb’s single-writer write transaction: each increment / try_acquire does its read-modify-write inside one transaction (ADR 000004). redb is fully synchronous; ADR 000011’s async-aware seam is this KvBackend impl — when host calls go async, the commits move to a blocking pool here without touching callers.

Implementations

impl RedbBackend

pub fn open(path: impl AsRef<Path>) -> Result<Self>

Open (or create) the redb database at path.

Trait Implementations

impl KvBackend for RedbBackend

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

fn set(&self, key: &[u8], value: Vec<u8>)

fn delete(&self, key: &[u8])

fn increment(&self, key: &[u8], delta: i64) -> i64

Atomic add-and-get. An unset counter starts at 0; delta is signed.

fn try_acquire( &self, key: &[u8], cost: u64, spec: Bucket, now_ms: u64, ) -> Acquire

Atomic token-bucket acquire against the now_ms request-clock snapshot. The refill + counting stay host-native (ADR 000005) — they never cross the WASM boundary; the filter only decided to consult the limiter.