OffsetStore

streamweave_offset::offset

Trait OffsetStore 

Source 
pub trait OffsetStore:
    Send
    + Sync
    + Debug {
    // Required methods
    fn get(&self, source: &str) -> OffsetResult<Option<Offset>>;
    fn commit(&self, source: &str, offset: Offset) -> OffsetResult<()>;
    fn get_all(&self) -> OffsetResult<HashMap<String, Offset>>;
    fn clear(&self, source: &str) -> OffsetResult<()>;
    fn clear_all(&self) -> OffsetResult<()>;
}
Expand description

Trait for offset storage backends.

Implementations of this trait handle persisting and retrieving offsets.

Required Methods§

Source

fn get(&self, source: &str) -> OffsetResult<Option<Offset>>

Get the committed offset for a source.

Source

fn commit(&self, source: &str, offset: Offset) -> OffsetResult<()>

Commit an offset for a source.

Source

fn get_all(&self) -> OffsetResult<HashMap<String, Offset>>

Get all committed offsets.

Source

fn clear(&self, source: &str) -> OffsetResult<()>

Clear the offset for a source.

Source

fn clear_all(&self) -> OffsetResult<()>

Clear all offsets.

Implementors§