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,
    pub passed_actors: Vec<TypedId<6>>,
}

Fields§

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

Tracing context for the current epoch of this barrier.

§passed_actors: Vec<TypedId<6>>

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

Implementations§

Source§

impl DispatcherBarrier

Source

pub fn to_protobuf(&self) -> PbBarrier