Struct SqliteMailboxStore 

pub struct SqliteMailboxStore { /* private fields */ }

A MailboxStore backed by a SQLite database.

Thread safety: a Mutex<Connection> serialises all writes, which is sufficient for the atomic-claim guarantee (the UPDATE WHERE state='unread' rowcount test).

Implementations

impl SqliteMailboxStore

pub fn open(path: &str) -> Result<Self, StoreError>

Open (or create) a store at the given file path.

pub fn open_in_memory() -> Result<Self, StoreError>

Open a transient in-memory store (useful in tests).

Trait Implementations

impl MailboxStore for SqliteMailboxStore

type Msg = Message

The message type stored by this implementation.

type Task = Task

The task type stored by this implementation.

type Error = StoreError

The error type returned by store operations.

fn post(&self, msg: &Message) -> Result<(), StoreError>

Post a message into the mailbox.

fn inbox(&self, team_id: &str, to: &str) -> Result<Vec<Message>, StoreError>

Return all unread messages addressed to to in team_id.

fn claim(&self, message_id: Uuid) -> Result<bool, StoreError>

Atomic claim: transition message state from Unread to Delivered.

fn consume(&self, message_id: Uuid) -> Result<(), StoreError>

Mark a message as Consumed.

fn unclaim(&self, message_id: Uuid) -> Result<(), StoreError>

Roll back a claim: transition message state from Delivered to Unread.

fn task_create(&self, task: &Task) -> Result<(), StoreError>

Insert a new task.

fn task_update( &self, id: Uuid, state: MailboxTaskState, note: Option<&str>, ) -> Result<(), StoreError>

Advance a task’s state, optionally recording a note.

fn task_list(&self, team_id: &str) -> Result<Vec<Task>, StoreError>

Return all tasks for a team.