risingwave_connector::sink

Trait LogSinker

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

Required Methods§

Source

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

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§