Trait OutboxOffsetStore 

pub trait OutboxOffsetStore:
    Send
    + Sync
    + 'static {
    // Required methods
    fn load(&self) -> HashMap<String, u64>;
    fn save(&self, offsets: &HashMap<String, u64>);
}

Pluggable per-pid offset persistence. load/save return offsets keyed by persistence_id.

Required Methods

fn load(&self) -> HashMap<String, u64>

fn save(&self, offsets: &HashMap<String, u64>)

Implementors

impl OutboxOffsetStore for InMemoryOffsetStore

impl<J: Journal> OutboxOffsetStore for JournalOffsetStore<J>