Struct ClusterController 

pub struct ClusterController { /* private fields */ }

Facade composing the cluster-control primitives.

Implementations

impl ClusterController

pub fn new( instance_id: NodeId, kv: Arc<dyn ClusterKv>, snapshot: Option<Arc<AssignmentSnapshotStore>>, members_rx: Receiver<Vec<NodeInfo>>, ) -> Self

Wrap the given primitives.

pub fn cluster_min_watermark(&self) -> Option<i64>

Latest cluster-wide minimum watermark seen by this instance. None until the leader has published a Commit with a populated min_watermark_ms.

pub fn publish_cluster_min_watermark(&self, wm: i64)

Leader-side monotonic publish. The leader computes the cluster-wide minimum watermark in await_prepare_quorum (its own local watermark folded with every follower’s ack) and must mirror it into the controller atomic so its own operators see the same value that followers pick up via observe_barrier on the matching Commit. Never lowers the published value — event-time progress is monotonic.

pub fn instance_id(&self) -> NodeId

This instance’s ID.

pub fn current_leader(&self) -> Option<NodeId>

Current leader (lowest id among Active peers plus self).

pub fn is_leader(&self) -> bool

True if this instance is currently the leader.

pub fn live_instances(&self) -> Vec<NodeId>

Live instance IDs: Active peers plus self.

pub fn members_watch(&self) -> Receiver<Vec<NodeInfo>>

Cloneable membership watch. Background tasks subscribe to this to react to join/leave events (changed().await) without polling Self::live_instances on a timer.

pub async fn announce_barrier( &self, ann: &BarrierAnnouncement, ) -> Result<(), String>

Leader-side announce.

Errors

Propagates BarrierCoordinator::announce errors.

pub async fn observe_barrier( &self, ) -> Result<Option<BarrierAnnouncement>, String>

Follower-side observe; Ok(None) if no leader is visible.

As a side effect, a Commit announcement with a populated min_watermark_ms updates the shared cluster-min-watermark atomic so operators on this instance see the cluster-wide minimum without a separate polling path.

Errors

Propagates BarrierCoordinator::observe errors.

pub async fn ack_barrier(&self, ack: &BarrierAck) -> Result<(), String>

Follower-side ack.

Errors

Propagates BarrierCoordinator::ack errors.

pub async fn wait_for_quorum( &self, epoch: u64, expected: &[NodeId], deadline: Duration, ) -> QuorumOutcome

Leader-side: poll until quorum or deadline.

pub fn snapshot_store(&self) -> Option<&AssignmentSnapshotStore>

Assignment snapshot store, if configured.

Trait Implementations

impl Debug for ClusterController

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.