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.

PipelineIdentity

SHA-256 identity of the logical pipeline and recovery-state ABI.

Enums

DurableCheckpointPhase

Durable publication state of a checkpoint manifest.

Constants

CHECKPOINT_MANIFEST_VERSION

Current checkpoint manifest format. Older manifests are rejected rather than guessed at recovery time. Version 6 binds recovery to the durable key-partitioning ABI.

PIPELINE_IDENTITY_VERSION

Canonical pipeline-identity payload version.