Trait SinkWithCheckpoints 

pub trait SinkWithCheckpoints: SinkConnect {
    type CheckpointStore: CheckpointStore;

    // Required method
    fn table_checkpoints(&self, table: String) -> Self::CheckpointStore;
}

Sink that can open a SurrealDB-table CheckpointStore for the same SDK major.

Embedders pick a sink crate (surreal-sync-surreal with v2 / v3); that type carries the correct checkpoint backend. Origin run / run_sync APIs call this when --checkpoints-surreal-table is set — embedders never construct stores or clients by hand.

Filesystem checkpoints (--checkpoint-dir) are handled by the source crate, not this trait.

Required Associated Types

type CheckpointStore: CheckpointStore

Checkpoint store that matches this sink’s SurrealDB SDK major.

Required Methods

fn table_checkpoints(&self, table: String) -> Self::CheckpointStore

Build a table-backed checkpoint store reusing this connected sink’s client.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors