package
3.65.0
Repository: https://github.com/jeffail/benthos.git
Documentation: pkg.go.dev

# Functions

New returns a new checkpointer.
NewCapped returns a new capped checkpointer.

# Structs

Capped receives an ordered feed of integer based offsets being tracked, and an unordered feed of integer based offsets that are resolved, and is able to return the highest offset currently able to be committed such that an unresolved offset is never committed.
Type keeps track of a sequence of pending checkpoint payloads, and as pending checkpoints are resolved it retains the latest fully resolved payload in the sequence where all prior sequence checkpoints are also resolved.