Struct DistributedStreamCoordinator 

pub struct DistributedStreamCoordinator { /* private fields */ }

Distributed stream coordinator.

Implementations

impl DistributedStreamCoordinator

pub fn new( config: CoordinatorConfig, sink: Arc<dyn StreamSink>, shipper: Arc<EventShipper>, ) -> CoordinatorResult<Self>

Build a coordinator.

pub fn stats(&self) -> &Arc<CoordinatorStats>

Stats accessor.

pub fn shard_manager(&self) -> &ShardManager

Shard manager handle.

pub fn current_assignment(&self) -> ShardAssignment

Latest installed assignment.

pub fn local_node(&self) -> &NodeId

Local node identifier.

pub fn n_shards(&self) -> u32

Number of shards configured for the coordinator.

pub async fn join(&self, node: NodeId) -> CoordinatorResult<RebalancePlan>

Register a node with the coordinator (typically the local node when the cluster boots, then any peer nodes as they appear).

pub async fn leave(&self, node: &str) -> CoordinatorResult<RebalancePlan>

Deregister a node.

pub fn install_assignment(&self, assignment: ShardAssignment) -> RebalancePlan

Apply an assignment that was committed elsewhere (e.g. seen on a Raft follower). The shard manager and the coordinator’s cached assignment are updated to match. No new Raft proposal is issued.

pub async fn route( &self, partition_key: &str, payload: &Value, ) -> CoordinatorResult<RoutedEvent>

Decide which node owns the shard for partition_key, ship the event there, and return a RoutedEvent describing the decision.

pub fn shard_for_key_value(&self, partition_key: &str) -> Option<ShardId>

Compute the shard id for a partition key without performing any I/O.