pub type PbAddMutation = AddMutation;
Expand description
Alias for AddMutation
.
Aliased Type§
struct PbAddMutation {
pub actor_dispatchers: HashMap<u32, Dispatchers>,
pub added_actors: Vec<u32>,
pub actor_splits: HashMap<u32, ConnectorSplits>,
pub pause: bool,
pub subscriptions_to_add: Vec<SubscriptionUpstreamInfo>,
}
Fields§
§actor_dispatchers: HashMap<u32, Dispatchers>
New dispatchers for each actor.
added_actors: Vec<u32>
All actors to be added (to the main connected component of the graph) in this update.
actor_splits: HashMap<u32, 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>