Module offset 

Offset tracking for resumable pipeline processing.

This module provides abstractions for tracking processing offsets, enabling pipelines to resume from where they left off after restarts.

Structs

FileOffsetStore

File-based offset store.

InMemoryOffsetStore

In-memory offset store.

OffsetTracker

Tracks processing offsets with configurable commit strategies.

Enums

CommitStrategy

Strategy for committing offsets.

Offset

Represents a processing offset.

OffsetError

Error type for offset operations.

OffsetResetPolicy

Policy for resetting offsets when no committed offset is found.

Traits

OffsetStore

Trait for offset storage backends.

Type Aliases

OffsetResult

Result type for offset operations.