risingwave_stream::executor

Type Alias DispatcherBarrier

source 
pub type DispatcherBarrier = BarrierInner<()>;

Aliased Type§

struct DispatcherBarrier {
    pub epoch: EpochPair,
    pub mutation: (),
    pub kind: BarrierKind,
    pub tracing_context: TracingContext,
    pub passed_actors: Vec<u32>,
}

Fields§

§epoch: EpochPair§mutation: ()§kind: BarrierKind§tracing_context: TracingContext

Tracing context for the current epoch of this barrier.

§passed_actors: Vec<u32>

The actors that this barrier has passed locally. Used for debugging only.

Implementations§