risingwave_connector::sink

Trait LogSinker

source 
pub trait LogSinker: 'static {
    // Required method
    fn consume_log_and_sink<'life0, 'async_trait>(
        self,
        log_reader: &'life0 mut (impl 'async_trait + SinkLogReader),
    ) -> Pin<Box<dyn Future<Output = Result<!>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

Required Methods§

source

fn consume_log_and_sink<'life0, 'async_trait>( self, log_reader: &'life0 mut (impl 'async_trait + SinkLogReader), ) -> Pin<Box<dyn Future<Output = Result<!>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Object Safety§

This trait is not object safe.

Implementors§