go_zoom_kinesis::store

Trait CheckpointStoreTestExt

source 
pub trait CheckpointStoreTestExt: CheckpointStore {
    // Provided methods
    fn timeout(&self) -> Duration { ... }
    fn get_all_checkpoints(
        &self,
    ) -> impl Future<Output = Result<HashMap<String, String>>> + Send { ... }
}

Provided Methods§

source

fn timeout(&self) -> Duration

Get the timeout for checkpoint operations (for testing)

source

fn get_all_checkpoints( &self, ) -> impl Future<Output = Result<HashMap<String, String>>> + Send

Get all checkpoints for testing verification

Object Safety§

This trait is not object safe.

Implementors§