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

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§