Module checkpoint 

Checkpoint store abstraction for Stage 4 of improve().

Provides a generic key/timestamp storage interface used by sync_graph_to_session to track the high-water mark of edges that have already been merged into a session’s graph context.

Structs

SeaOrmCheckpointStore

SeaORM-backed implementation of CheckpointStore that writes to the graph_sync_checkpoints table.

Traits

CheckpointStore

Abstraction over persistent timestamp checkpoints keyed by string.

Functions

load_checkpoint

Load the checkpoint timestamp for a key from the graph_sync_checkpoints table, or None if the key does not exist.

save_checkpoint

Persist ts under key in the graph_sync_checkpoints table. Inserts a new row or updates the existing one (upsert on the primary key).