Struct InMemoryOffsetStore 

pub struct InMemoryOffsetStore { /* private fields */ }

In-memory offset store — useful for tests. State is kept in a Mutex<HashMap>; survives restarts of the publisher loop, but not process restarts.

Implementations

impl InMemoryOffsetStore

pub fn new() -> Self

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

Trait Implementations

impl Default for InMemoryOffsetStore

fn default() -> InMemoryOffsetStore

Returns the “default value” for a type.

impl OutboxOffsetStore for InMemoryOffsetStore

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

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