risingwave_stream::task::barrier_manager

Module await_epoch_completed_future

Source

Functions§

instrument_complete_barrier_future 🔒

Type Aliases§

AwaitEpochCompletedFuture 🔒