risingwave_pb::stream_plan

Type Alias PbBarrier

source
pub type PbBarrier = Barrier;
Expand description

Alias for Barrier.

Aliased Type§

struct PbBarrier {
    pub epoch: Option<Epoch>,
    pub mutation: Option<BarrierMutation>,
    pub tracing_context: HashMap<String, String>,
    pub kind: i32,
    pub passed_actors: Vec<u32>,
}

Fields§

§epoch: Option<Epoch>§mutation: Option<BarrierMutation>§tracing_context: HashMap<String, String>

Used for tracing.

§kind: i32

The kind of the barrier.

§passed_actors: Vec<u32>

Record the actors that the barrier has passed. Only used for debugging.