Struct OffsetTracker 

pub struct OffsetTracker { /* private fields */ }

Tracks processing offsets with configurable commit strategies.

The OffsetTracker wraps an OffsetStore and provides convenient methods for tracking and committing offsets based on the configured strategy.

Implementations

impl OffsetTracker

pub fn new(store: Box<dyn OffsetStore>) -> Self

Creates a new offset tracker with the given store and default settings.

pub fn with_strategy( store: Box<dyn OffsetStore>, strategy: CommitStrategy, ) -> Self

Creates a new offset tracker with the specified commit strategy.

pub fn with_reset_policy(self, policy: OffsetResetPolicy) -> Self

Sets the offset reset policy.

pub fn get_offset(&self, source: &str) -> OffsetResult<Offset>

Gets the current committed offset for a source, applying the reset policy if no offset is found.

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

Records that an offset has been processed.

Based on the commit strategy, this may immediately commit the offset or hold it for later batch commit.

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

Commits the pending offset for a specific source.

This is useful for manual commit strategy or when forcing a commit.

pub fn commit_all(&self) -> OffsetResult<()>

Commits all pending offsets.

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

Resets the offset for a source to the specified value.

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

Clears the offset for a source.

pub fn strategy(&self) -> CommitStrategy

Returns the current commit strategy.

pub fn reset_policy(&self) -> OffsetResetPolicy

Returns the current reset policy.

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

Gets all committed offsets.

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

Gets all pending offsets (not yet committed).

Trait Implementations

impl Debug for OffsetTracker

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

Formats the value using the given formatter.