Module await_epoch_completed_future

risingwave_stream::task::barrier_worker

Module await_epoch_completed_future 

Source

Functions§

instrument_complete_barrier_future 🔒

Type Aliases§

AwaitEpochCompletedFuture 🔒