Module checkpoint 

Checkpointing for fast recovery Checkpoint infrastructure for state persistence and recovery.

• layout: object-store checkpoint layout
• checkpointer: Async checkpoint persistence via object stores
• source_offsets: Typed source position tracking

Modules

checkpointer

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

layout

Object-store checkpoint layout with UUID v7 identifiers. Object-store checkpoint layout for distributed checkpoints.

recovery

Distributed recovery manager. Distributed recovery manager.

source_offsets

Typed source position tracking for checkpoint recovery. Typed source position tracking for checkpoint recovery.

Structs

Checkpoint

A completed checkpoint on disk.

CheckpointMetadata

Checkpoint metadata stored alongside checkpoint data.