Module checkpoint_manifest 

Unified checkpoint manifest types Versioned checkpoint manifest.

Structs

ByteRange

A byte range within an immutable node data object.

ChannelProgress

Watermark and idleness state for one stable input channel.

CheckpointManifest

A point-in-time snapshot of one participant’s pipeline state.

ConnectorCheckpoint

Connector-owned offset map stored at the exact checkpoint cut.

ManifestValidationError

Errors found during manifest validation.

NodeDataObject

The one data object written by this participant for this checkpoint.

PipelineIdentity

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

PreparedSinkArtifactIntent

Recovery evidence persisted before a checkpoint-committable sink may write.

PreparedSinkDescriptor

Opaque phase-one sink descriptor stored in the current node data object.

ReferencedStateChunk

Metadata and exact logical reference count for an older immutable object.

StateChunkId

Stable identity of one immutable node data object.

StateFrame

A checksummed state payload in the current or a prior node data object.

Enums

StateFrameKey

State-frame identity. Whole-operator metadata and vnode-keyed state are distinct.

Constants

CHECKPOINT_MANIFEST_VERSION

Current checkpoint manifest format. Every other version is rejected.

PIPELINE_IDENTITY_VERSION

Canonical pipeline-identity payload version.

PREPARED_SINK_DESCRIPTOR_VERSION

Runtime envelope used for prepared sink descriptors.

Functions

checkpoint_artifact_intent_sha256

SHA-256 for one optional sink artifact intent.

checkpoint_descriptor_sha256

Domain-separated digest for an optional prepared sink descriptor.

checkpoint_sha256

SHA-256 helper used by capture and focused format tests.