Struct BarrierCoordinator 

pub struct BarrierCoordinator { /* private fields */ }

Cross-instance barrier coordination.

Implementations

impl BarrierCoordinator

pub fn new(kv: Arc<dyn ClusterKv>) -> Self

Wrap a KV implementation.

pub fn set_leader_election( &mut self, instance_id: NodeId, members_rx: Receiver<Vec<NodeInfo>>, )

Configure the leader election state used to validate incoming leader identity.

pub async fn start_server( &self, bind_addr: SocketAddr, advertise_host: Option<String>, query_handler: QueryHandlerSlot, ) -> Result<SocketAddr, String>

Bind and run the follower’s direct gRPC barrier sync server.

Errors

Returns an error string on bind or socket address retrieval failures.

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

Leader-side announce.

Errors

Returns a string on JSON encode failure.

pub fn announcement_watch( &self, ) -> Option<Receiver<Option<BarrierAnnouncement>>>

Watch over gRPC-delivered announcements, for push-driven waits (the decision wait and the Aligned resume gate). None until the gRPC server is started — gossip-KV-only deployments fall back to polling observe.

pub async fn observe( &self, leader: NodeId, ) -> Result<Option<BarrierAnnouncement>, String>

Follower-side observe — returns the latest announcement (non-destructive; repeated calls return the same value until a newer one arrives, matching the gossip-KV fallback). Callers already dedup by epoch/phase. The gRPC-delivered value and the gossip-KV value are merged by epoch (higher wins — epochs are never reused: failed ones are abandoned); within an epoch the gRPC value wins, since RPC arrival order is authoritative while gossip may lag.

Errors

Returns a string on JSON decode failure.

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

Follower-side ack.

Errors

Returns a string on JSON encode failure.

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

Leader-side: wait until quorum or deadline.

Trait Implementations

impl Debug for BarrierCoordinator

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

Formats the value using the given formatter.

impl Drop for BarrierCoordinator

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.