pub type PbInjectBarrierRequest = InjectBarrierRequest;Expand description
Alias for InjectBarrierRequest.
Aliased Type§
struct PbInjectBarrierRequest {
pub request_id: String,
pub barrier: Option<Barrier>,
pub actor_ids_to_collect: Vec<u32>,
pub table_ids_to_sync: Vec<u32>,
pub partial_graph_id: u64,
pub broadcast_info: Vec<ActorInfo>,
pub actors_to_build: Vec<StreamActor>,
pub subscriptions_to_add: Vec<SubscriptionUpstreamInfo>,
pub subscriptions_to_remove: Vec<SubscriptionUpstreamInfo>,
}Fields§
§request_id: String§barrier: Option<Barrier>§actor_ids_to_collect: Vec<u32>§table_ids_to_sync: Vec<u32>§partial_graph_id: u64§broadcast_info: Vec<ActorInfo>§actors_to_build: Vec<StreamActor>§subscriptions_to_add: Vec<SubscriptionUpstreamInfo>§subscriptions_to_remove: Vec<SubscriptionUpstreamInfo>