Skip to main content

ProviderV2ProxyInterface

Trait ProviderV2ProxyInterface 

Source
pub trait ProviderV2ProxyInterface: Send + Sync {
    type StartResponseFut: Future<Output = Result<(), Error>> + Send;
    type StopResponseFut: Future<Output = Result<(), Error>> + Send;
    type TerminateResponseFut: Future<Output = Result<(), Error>> + Send;
    type GetKnownCategoriesResponseFut: Future<Output = Result<Vec<KnownCategory>, Error>> + Send;

    // Required methods
    fn initialize(&self, config: ProviderConfigV2) -> Result<(), Error>;
    fn start(&self, options: &StartOptions) -> Self::StartResponseFut;
    fn stop(&self) -> Self::StopResponseFut;
    fn terminate(&self) -> Self::TerminateResponseFut;
    fn get_known_categories(&self) -> Self::GetKnownCategoriesResponseFut;
    fn notify_buffer_saved(
        &self,
        wrapped_count: u32,
        durable_data_end: u64,
    ) -> Result<(), Error>;
    fn flush(&self) -> Result<(), Error>;
}

Required Associated Types§

Required Methods§

Source

fn initialize(&self, config: ProviderConfigV2) -> Result<(), Error>

Source

fn start(&self, options: &StartOptions) -> Self::StartResponseFut

Source

fn stop(&self) -> Self::StopResponseFut

Source

fn terminate(&self) -> Self::TerminateResponseFut

Source

fn get_known_categories(&self) -> Self::GetKnownCategoriesResponseFut

Source

fn notify_buffer_saved( &self, wrapped_count: u32, durable_data_end: u64, ) -> Result<(), Error>

Source

fn flush(&self) -> Result<(), Error>

Implementors§