Struct ClusterConfig 

pub struct ClusterConfig {
    pub node_id: String,
    pub bind_address: SocketAddr,
    pub members: Vec<String>,
    pub peers: Vec<ClusterPeer>,
    pub failover_poll_interval_ms: Option<u64>,
    pub failover_confirmations: Option<u32>,
}

Distributed-cluster membership for the haematite backend, from [store.cluster].

This is the minimal, well-defaulted seam that turns the single-node haematite store into a distributed one (SS-2). A “cluster of one” — node_id set, members either empty or naming only node_id, and no peers — is a valid, non-flaky configuration: election self-quorums (quorum denominator 1) and the node boots through the production builder as the fenced owner of its shards.

Fields

node_id: String

This node’s globally-unique distribution name (e.g. node-0@127.0.0.1). Used as the local endpoint name and the local membership identity.

bind_address: SocketAddr

The replication endpoint listen address this node binds for peer quorum/election traffic (e.g. 127.0.0.1:7000).

members: Vec<String>

The FULL cluster membership by node id — the quorum DENOMINATOR. Never the reachable subset. May be empty or omit peers for a cluster of one, in which case it is treated as [node_id] (denominator 1). node_id is always counted in the denominator whether or not it appears here.

peers: Vec<ClusterPeer>

Dialable peers (name + address) this node connects to for replication. A cluster of one leaves this empty. Peers not in members do not inflate the quorum denominator.

failover_poll_interval_ms: Option<u64>

SS-5b automatic-failover poll interval in milliseconds: how often the cluster supervisor checks each watched peer’s replication liveness. Defaults to DEFAULT_FAILOVER_POLL_INTERVAL_MS when omitted.

failover_confirmations: Option<u32>

SS-5b debounce: the number of CONSECUTIVE polls a peer must be observed disconnected before its shards are adopted, so a transient blip does not trigger a disruptive failover. Defaults to DEFAULT_FAILOVER_CONFIRMATIONS when omitted; must be at least one.

Trait Implementations

impl Clone for ClusterConfig

fn clone(&self) -> ClusterConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ClusterConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ClusterConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for ClusterConfig

impl PartialEq for ClusterConfig

fn eq(&self, other: &ClusterConfig) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for ClusterConfig