Struct InMemoryStateBackend 

pub struct InMemoryStateBackend { /* private fields */ }

In-memory StateBackend — fast but not durable across process restarts.

Implementations

impl InMemoryStateBackend

pub fn new() -> Self

Create an empty in-memory backend.

pub fn version(&self) -> Result<u64, StreamError>

Current logical version.

Trait Implementations

impl Default for InMemoryStateBackend

fn default() -> Self

Returns the “default value” for a type.

impl StateBackend for InMemoryStateBackend

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

Return the value for the given key, or None if absent.

fn put(&self, key: &[u8], value: &[u8]) -> Result<(), StreamError>

Insert or overwrite a key-value pair.

fn delete(&self, key: &[u8]) -> Result<bool, StreamError>

Remove a key. Returns true if the key previously existed.

fn range_scan( &self, prefix: &[u8], ) -> Result<Vec<(Vec<u8>, Vec<u8>)>, StreamError>

Return all entries whose key starts with prefix.

fn checkpoint(&self, checkpoint_id: u64) -> Result<Vec<u8>, StreamError>

Serialize the current state into an opaque byte snapshot tagged with checkpoint_id.

fn restore(&self, snapshot: &[u8]) -> Result<(), StreamError>

Replace current state with the content of a previously-created snapshot.

fn size_bytes(&self) -> usize

Approximate heap/disk footprint in bytes.