Struct FileOffsetStore 

pub struct FileOffsetStore { /* private fields */ }

File-based offset store.

Persists offsets to a JSON file on disk.

File-based offset store implementation.

Implementations

impl FileOffsetStore

pub fn new<P: AsRef<Path>>(path: P) -> OffsetResult<Self>

Creates a new file-based offset store.

pub fn path(&self) -> &Path

Returns the path to the offset file.

Trait Implementations

impl Clone for FileOffsetStore

fn clone(&self) -> FileOffsetStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FileOffsetStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl OffsetStore for FileOffsetStore

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

Get the committed offset for a source.

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

Commit an offset for a source.

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

Get all committed offsets.

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

Clear the offset for a source.

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

Clear all offsets.