Module checkpointer 

Async checkpoint persistence via object stores. Async checkpoint persistence via object stores.

The Checkpointer trait abstracts checkpoint I/O so that the checkpoint coordinator doesn’t need to know whether state is persisted to local disk, S3, GCS, or Azure Blob.

ObjectStoreCheckpointer is the production implementation that writes to any object_store::ObjectStore backend with:

• Concurrent partition uploads via JoinSet
• SHA-256 integrity digests
• Exponential backoff retry on transient errors

Structs

ObjectStoreCheckpointer

Production Checkpointer backed by an [ObjectStore].

Enums

CheckpointerError

Errors from checkpoint persistence operations.

Traits

Checkpointer

Async trait for checkpoint persistence operations.

Functions

verify_integrity

Verify a loaded artifact against its expected SHA-256 digest.