set_checkpoint

Function set_checkpoint 

Source
async fn set_checkpoint(
    pool: &SqlitePool,
    source: &str,
    cursor_val: i64,
) -> Result<()>
Expand description

Persists the sync checkpoint for a connector.

Uses an upsert to create or update the checkpoint row. The cursor value is typically the maximum updated_at timestamp seen during the sync.