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.