Module checkpoint_manifest 

Unified checkpoint manifest types Checkpoint manifest types.

Manifests are JSON for debuggability. Large operator state goes into a separate state.bin sidecar referenced by offset/length in the manifest.

Structs

CheckpointManifest

A point-in-time snapshot of all pipeline state.

ConnectorCheckpoint

Connector-agnostic offset container.

ManifestValidationError

Errors found during manifest validation.

OperatorCheckpoint

Serialized operator state stored in the manifest.

Enums

SinkCommitStatus

Per-sink commit status tracked during the checkpoint commit phase.

Constants

DEFAULT_VNODE_COUNT

Default virtual partition count for state key distribution.