risingwave_connector::sink::log_store

Trait LogStoreFactory

source 
pub trait LogStoreFactory: Send + 'static {
    type Reader: LogReader;
    type Writer: LogWriter;

    // Required method
    fn build(self) -> impl Future<Output = (Self::Reader, Self::Writer)> + Send;
}

Required Associated Types§

source

type Reader: LogReader

source

type Writer: LogWriter

Required Methods§

source

fn build(self) -> impl Future<Output = (Self::Reader, Self::Writer)> + Send

Object Safety§

This trait is not object safe.

Implementors§