Struct InMemoryCheckpointStore 

pub struct InMemoryCheckpointStore { /* private fields */ }

In-memory CheckpointStore: holds the latest offset in a mutex. Survives pause/resume and restart-within-process, but not a process restart — use it for tests and for sources that re-derive their position from the backend.

Trait Implementations

impl CheckpointStore for InMemoryCheckpointStore

fn save<'life0, 'life1, 'async_trait>( &'life0 self, offset: &'life1 SourceOffset, ) -> Pin<Box<dyn Future<Output = Result<(), ConnectError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Persist offset as the latest committed position. Called only after the records it covers are durable in the sink.

fn load<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<SourceOffset>, ConnectError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Load the last persisted position, or None if none was ever saved (a fresh start). Called once before the first poll.

impl Debug for InMemoryCheckpointStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for InMemoryCheckpointStore

fn default() -> InMemoryCheckpointStore

Returns the “default value” for a type.