Struct SwarmStore 

pub struct SwarmStore { /* private fields */ }

Cloneable access to the gateway’s durable swarm catalog.

Implementations

impl SwarmStore

pub async fn summaries(&self) -> Result<Vec<SwarmSummary>>

Returns every swarm ordered by its stable identifier.

pub async fn snapshot_for_session( &self, session_id: &str, ) -> Result<Option<SwarmSnapshot>>

Resolves the swarm and handle for one participating session.

pub async fn post( &self, sender_session_id: &str, text: String, ) -> Result<SwarmPost>

Posts one durable board entry and resolves all @handle recipients.

pub async fn board_page( &self, swarm_id: &str, before_sequence: Option<u64>, limit: usize, ) -> Result<BoardPage>

Loads one newest-first board page before an optional sequence cursor.

pub async fn pending_deliveries( &self, target_session_id: &str, ) -> Result<Vec<PendingDelivery>>

Returns messages still awaiting one target session’s acknowledgement.

pub async fn acknowledge( &self, message_id: &str, target_session_id: &str, ) -> Result<bool>

Acknowledges one target’s message delivery.

Returns false when that target already acknowledged the entry.

Trait Implementations

impl Clone for SwarmStore

fn clone(&self) -> SwarmStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl SwarmBackend for SwarmStore

fn active<'a>(&'a self, session_id: &'a str) -> BoxFuture<'a, Result<bool>>

Reports whether the session currently belongs to a swarm.

fn roster<'a>(&'a self, session_id: &'a str) -> BoxFuture<'a, Result<String>>

Returns the caller’s current roster as model-readable text.

fn read<'a>(&'a self, session_id: &'a str) -> BoxFuture<'a, Result<String>>

Returns the caller’s recent shared board as model-readable text.

fn post<'a>( &'a self, session_id: &'a str, message: String, ) -> BoxFuture<'a, Result<String>>

Durably posts a message and schedules any mentioned peers for delivery.