Type Alias PbAddMutation 

pub type PbAddMutation = AddMutation;

Aliased Type

pub struct PbAddMutation {
    pub actor_dispatchers: HashMap<TypedId<6>, Dispatchers>,
    pub added_actors: Vec<TypedId<6>>,
    pub actor_splits: HashMap<TypedId<6>, ConnectorSplits>,
    pub pause: bool,
    pub subscriptions_to_add: Vec<SubscriptionUpstreamInfo>,
    pub backfill_nodes_to_pause: Vec<TypedId<5>>,
    pub actor_cdc_table_snapshot_splits: Option<CdcTableSnapshotSplitsWithGeneration>,
    pub new_upstream_sinks: HashMap<TypedId<5>, NewUpstreamSink>,
}

Fields

actor_dispatchers: HashMap<TypedId<6>, Dispatchers>

New dispatchers for each actor.

added_actors: Vec<TypedId<6>>

All actors to be added (to the main connected component of the graph) in this update.

actor_splits: HashMap<TypedId<6>, ConnectorSplits>

We may embed a source change split mutation here. Source and SourceBackfill are handled together here. TODO: we may allow multiple mutations in a single barrier.

pause: bool

We may embed a pause mutation here. TODO: we may allow multiple mutations in a single barrier.

subscriptions_to_add: Vec<SubscriptionUpstreamInfo>

backfill_nodes_to_pause: Vec<TypedId<5>>

nodes which should be paused initially.

actor_cdc_table_snapshot_splits: Option<CdcTableSnapshotSplitsWithGeneration>

CDC table snapshot splits

new_upstream_sinks: HashMap<TypedId<5>, NewUpstreamSink>

Use downstream_fragment_id as keys.