Trait ReplayableSourceProvider 

pub trait ReplayableSourceProvider: Send {
    // Required methods
    fn provider_kind(&self) -> SourceProviderKindV1;
    fn fetch<'a>(
        &'a mut self,
        request: &'a SourceFetchRequestV1,
    ) -> SourceProviderFuture<'a>;
}

Provider owns replay position and stable raw-record identity; it never decodes documents.

Required Methods

fn provider_kind(&self) -> SourceProviderKindV1

fn fetch<'a>( &'a mut self, request: &'a SourceFetchRequestV1, ) -> SourceProviderFuture<'a>

Dyn Compatibility

This trait is dyn compatible.

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

Implementors