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_lease_store(&self, store: Arc<LeaderLeaseStore>)

Install the durable authority used to validate clustered reversible barrier phases. Without it, clustered Prepare and Aligned traffic fails closed.

pub fn checkpoint_authority( &self, ) -> Result<Arc<LeaderLeaseStore>, ClusterCheckpointAuthorityError>

Exact durable authority installed for clustered barriers and checkpoint decisions.

Embedded and single-node runtimes do not call this path. A cluster runtime that omitted authority wiring fails closed instead of falling back to standalone outcome objects.

Errors

Returns NotConfigured when durable cluster checkpoint authority is not installed.

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

Configure membership used to target active barrier peers. Gossip election is not a barrier authority boundary.

pub fn prepare_received_at( &self, prepare: &BarrierAnnouncement, ) -> Option<Instant>

Local monotonic receipt time for this exact gRPC Prepare.

pub async fn start_server( &self, bind_addr: SocketAddr, advertise_host: Option<String>, ) -> 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 confirm_remote_leader_proof( &self, proof: &LeaderProof, deadline: Instant, ) -> Result<bool, String>

Ask one exact remote process to confirm a proof already read from durable authority.

The response echoes only a fresh challenge id. It never returns a process-local or durable fencing token.

Errors

Fails when the proof, peer address, RPC, acknowledgement, or deadline is invalid.

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

Leader-side announcement for terminal, aligned, and assignment-less local/KV phases.

Errors

Assignment-certified Prepare must use Self::announce_prepare. Assignment-certified reversible phases require a started leased barrier server, and Aligned requires the exact Prepare to have completed Self::wait_for_quorum. Other errors propagate validation, encoding, and publication failures.

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

Durably publish one assignment-certified Prepare and immediately start its direct fan-out.

Errors

Rejects a different phase, an assignment-less announcement, a zero/indivisible quorum window, malformed authority, conflicting in-flight Prepare state, or publication 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 the merged gossip history.

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, prepare: &BarrierAnnouncement, 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.