Struct Store 

pub struct Store { /* private fields */ }

Implementations

impl Store

pub fn on_disk(path: &Path) -> Result<Self>

On-disk durable store (created if absent).

pub fn in_memory() -> Result<Self>

Ephemeral in-memory store — same API, nothing persists.

pub async fn enqueue(&self, recipient: String, value: Vec<u8>) -> Result<String>

Append value to recipient’s queue; returns the ack key.

pub async fn peek_oldest( &self, recipient: String, ) -> Result<Option<(String, Vec<u8>)>>

The oldest un-acked (key, value) for recipient, without removing it.

pub async fn ack(&self, key: String) -> Result<()>

Remove an acked message by key. Idempotent (removing an absent key is ok).

pub async fn depth(&self, recipient: String) -> Result<usize>

Count of un-acked messages for recipient.

pub async fn list(&self, recipient: String) -> Result<Vec<(String, Vec<u8>)>>

Every un-acked (key, value) for recipient, in FIFO order. Used to inspect a queue (e.g. list what’s still pending in the agent’s outbox).

pub async fn log_put(&self, rec: LogRecord) -> Result<()>

Insert or overwrite a log record (keyed by msg_id) and its per-peer index.

pub async fn log_set_state(&self, msg_id: String, state: String) -> Result<()>

Update the state of a logged message. No-op if the msg_id is unknown.

pub async fn log_get(&self, msg_id: String) -> Result<Option<LogRecord>>

The log record for a single msg_id, if any.

pub async fn log_by_peer( &self, peer: String, limit: usize, ) -> Result<Vec<LogRecord>>

The most recent limit log records for peer, in chronological order.

Trait Implementations

impl Clone for Store

fn clone(&self) -> Store

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.