risingwave_
connector
2.4.0-alpha
In risingwave_
connector::
sink::
log_
store
risingwave_connector
::
sink
::
log_store
Trait Alias
LogWriterPostFlushCurrentEpochFn
Copy item path
Source
trait LogWriterPostFlushCurrentEpochFn<'a> =
FnOnce
() -> BoxFuture<'a,
LogStoreResult
<
()
>>;