Struct StoreAndForward 

pub struct StoreAndForward<Q = InMemoryQueue, P: ConnectivityProbe = AlwaysOnlineProbe> { /* private fields */ }

Available on crate feature resilience only.

Store-and-forward pattern: stores operations when offline, replays on reconnect.

Implementations

impl StoreAndForward<InMemoryQueue, AlwaysOnlineProbe>

pub fn default_new() -> Self

Create a store-and-forward with in-memory queue and always-online probe.

impl<P: ConnectivityProbe> StoreAndForward<InMemoryQueue, P>

pub fn new(queue: InMemoryQueue, probe: P) -> Self

Create a new store-and-forward with the given queue and probe.

pub async fn execute<F, Fut>(&self, id: &str, f: F)

where F: FnOnce() -> Fut + Send, Fut: Future<Output = Result<(), String>> + Send,

Execute an operation; if it fails, store it for later replay.

pub async fn pending_count(&self) -> usize

Number of pending operations.

pub async fn peek_pending(&self) -> Vec<PendingOperation>

Peek at all pending operations (FIFO order).

pub async fn replay_all<F, Fut>( &self, handler: F, ) -> Result<ReplayReport, String>

where F: Fn(String) -> Fut + Send, Fut: Future<Output = Result<(), String>> + Send,

Replay all pending operations through the given handler.