risingwave_connector::sink

Trait SinkLogReader

source 
pub trait SinkLogReader:
    Send
    + Sized
    + 'static {
    // Required methods
    fn next_item(
        &mut self,
    ) -> impl Future<Output = LogStoreResult<(u64, LogStoreReadItem)>> + Send + '_;
    fn truncate(&mut self, offset: TruncateOffset) -> LogStoreResult<()>;
}

Required Methods§

source

fn next_item( &mut self, ) -> impl Future<Output = LogStoreResult<(u64, LogStoreReadItem)>> + Send + '_

Emit the next item.

The implementation should ensure that the future is cancellation safe.

source

fn truncate(&mut self, offset: TruncateOffset) -> LogStoreResult<()>

Mark that all items emitted so far have been consumed and it is safe to truncate the log from the current offset.

Object Safety§

This trait is not object safe.

Implementors§