Expand description
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§
- File
Offset Store - File-based offset store.
- InMemory
Offset Store - In-memory offset store.
- Offset
Tracker - Tracks processing offsets with configurable commit strategies.
Enums§
- Commit
Strategy - Strategy for committing offsets.
- Offset
- Represents a processing offset.
- Offset
Error - Error type for offset operations.
- Offset
Reset Policy - Policy for resetting offsets when no committed offset is found.
Traits§
- Offset
Store - Trait for offset storage backends.
Type Aliases§
- Offset
Result - Result type for offset operations.