Module store 

A durable, keep-until-acked FIFO queue — one logical queue per recipient key.

Backed by redb (pure Rust, ACID) on disk, or an in-memory backend for ephemeral use (tests, and the bus with no --db). Same code path either way.

Values are opaque bytes, so the same store serves the bus (message envelopes) and the agent’s outbound queue. Ordering is a global monotonic sequence, so a prefix range scan over a recipient yields FIFO. A message stays until Store::ack; redelivery after a crash is safe because the receiver dedupes by msg_id.

redb’s API is synchronous; each call runs on a blocking thread so the surface the rest of the async code sees is async. When Turso’s pure-Rust SDK matures this module is the single seam to swap.

Structs

LogRecord

One entry in the local conversation log. text may be None for records where only the fact of a message (not its body) needs keeping.

Store

Enums

Dir