Module checkpoint_store 

Checkpoint persistence trait and filesystem/object store implementations Provider-neutral checkpoint persistence over [object_store].

Structs

CheckpointManifestAbortSeal

Durable state returned after sealing one aborted participant manifest.

CheckpointSinkArtifactIntent

One connector’s bounded cleanup evidence persisted before begin_epoch.

ObjectStoreCheckpointStore

Checkpoint store backed by any [ObjectStore] implementation.

SubscriptionOrphanCleanup

Result of one bounded subscription-segment orphan scan.

Enums

CheckpointStoreError

Checkpoint persistence error.

Constants

DEFAULT_MAX_CHECKPOINT_NODE_DATA_BYTES

Default maximum size of one participant’s checkpoint data object.

MAX_CHECKPOINT_SINK_ARTIFACT_INTENT_AGGREGATE_BYTES

Maximum aggregate connector intent payload retained by one participant.

MAX_CHECKPOINT_SINK_ARTIFACT_INTENT_BYTES

Maximum connector artifact-intent payload accepted for one sink.

Traits

CheckpointStore

Immutable checkpoint storage contract.

Functions

checkpoint_artifact_identity_sha256

SHA-256 binding one active artifact inventory to one exact participant object namespace.

checkpoint_manifest_bytes

Exact canonical bytes persisted for a checkpoint manifest.

probe_object_store_conditional_create

Prove that conditional create rejects an existing object.

probe_object_store_conditional_update

Prove conditional create/update and stale-update rejection.

validate_max_checkpoint_node_data_bytes

Validate the configured per-node checkpoint byte budget.