Struct ClusterConfig 

pub struct ClusterConfig {

    pub node_id: String,
    pub roles: Vec<String>,
    pub bind_addr: SocketAddr,
    pub advertise_addr: SocketAddr,
    pub agent_addr: Option<SocketAddr>,
    pub seed_nodes: Vec<SocketAddr>,
    pub gossip_interval: Duration,
    pub probe_timeout: Duration,
    pub suspect_timeout: Duration,
    pub downing_timeout: Duration,
    pub remove_down_after: Duration,
    pub max_packet_size: usize,
    pub event_buffer: usize,
    pub request_timeout: Duration,
}

Configuration for one Datum cluster member.

Fields

node_id: String

Stable logical node id used by Datum control-plane APIs.

roles: Vec<String>

Akka-style role labels advertised in membership gossip.

bind_addr: SocketAddr

Local UDP address used for membership gossip.

advertise_addr: SocketAddr

Address peers should use to contact this node. If the port is 0, the bound UDP port is substituted at startup.

agent_addr: Option<SocketAddr>

DCP agent address peers should use for node-to-node control sessions.

ClusterAgent fills this from the bound DCP listener when it starts the agent and membership together. Bare membership nodes may leave it empty.

seed_nodes: Vec<SocketAddr>

Seed node UDP addresses. The seed identity is resolved by foca from the first announce reply, so only addresses are required here.

gossip_interval: Duration

Foca probe period and periodic gossip cadence.

probe_timeout: Duration

Direct probe round-trip timeout before foca asks indirect probes.

suspect_timeout: Duration

Foca suspect-to-down timeout. Keep this longer than the downing timeout when TimeoutDowning should make the public downing decision first.

downing_timeout: Duration

Default timeout used by crate::TimeoutDowning.

remove_down_after: Duration

How long foca remembers down identities before accepting the exact same identity again. New incarnations can rejoin before this expires.

max_packet_size: usize

Maximum UDP packet size foca will produce and consume.

event_buffer: usize

Bounded event-feed capacity for crate::MemberEvent subscribers.

request_timeout: Duration

Timeout for leave() and abort() oneshot replies.

Implementations

impl ClusterConfig

pub fn new(node_id: impl Into<String>) -> Self

Create a config with loopback defaults and no seed nodes.

pub fn with_roles( self, roles: impl IntoIterator<Item = impl Into<String>>, ) -> Self

Return a copy using the supplied roles.

pub fn with_seed_nodes( self, seed_nodes: impl IntoIterator<Item = SocketAddr>, ) -> Self

Return a copy using the supplied seed-node addresses.

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 Default for ClusterConfig

fn default() -> Self

Returns the “default value” for a type.