DispatcherBarrier

risingwave_stream::executor

Type Alias DispatcherBarrier 

Source 
pub type DispatcherBarrier = BarrierInner<()>;

Aliased Type§

pub struct DispatcherBarrier {
    pub epoch: EpochPair,
    pub mutation: (),
    pub kind: BarrierKind,
    pub tracing_context: TracingContext,
}

Fields§

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

Tracing context for the current epoch of this barrier.

Implementations§