risingwave_connector::sink::log_store

Trait LogWriter

Source 
pub trait LogWriter: Send {
    // Required methods
    fn init(
        &mut self,
        epoch: EpochPair,
        pause_read_on_bootstrap: bool,
    ) -> impl Future<Output = LogStoreResult<()>> + Send + '_;
    fn write_chunk(
        &mut self,
        chunk: StreamChunk,
    ) -> impl Future<Output = LogStoreResult<()>> + Send + '_;
    fn flush_current_epoch(
        &mut self,
        next_epoch: u64,
        options: FlushCurrentEpochOptions,
    ) -> impl Future<Output = LogStoreResult<LogWriterPostFlushCurrentEpoch<'_>>> + Send + '_;
    fn pause(&mut self) -> LogStoreResult<()>;
    fn resume(&mut self) -> LogStoreResult<()>;
}

Required Methods§

Source

fn init( &mut self, epoch: EpochPair, pause_read_on_bootstrap: bool, ) -> impl Future<Output = LogStoreResult<()>> + Send + '_

Initialize the log writer with an epoch

Source

fn write_chunk( &mut self, chunk: StreamChunk, ) -> impl Future<Output = LogStoreResult<()>> + Send + '_

Write a stream chunk to the log writer

Source

fn flush_current_epoch( &mut self, next_epoch: u64, options: FlushCurrentEpochOptions, ) -> impl Future<Output = LogStoreResult<LogWriterPostFlushCurrentEpoch<'_>>> + Send + '_

Mark current epoch as finished and sealed, and flush the unconsumed log data.

Source

fn pause(&mut self) -> LogStoreResult<()>

Source

fn resume(&mut self) -> LogStoreResult<()>

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§