Struct RepConfigBuilder 

pub struct RepConfigBuilder { /* private fields */ }

Builder for RepConfig.

Implementations

impl RepConfigBuilder

pub fn node_port(self, port: u16) -> Self

Sets the replication port.

pub fn node_type(self, node_type: NodeType) -> Self

Sets the node type.

pub fn election_timeout(self, timeout: Duration) -> Self

Sets the election timeout.

pub fn heartbeat_interval(self, interval: Duration) -> Self

Sets the heartbeat interval.

pub fn consistency_policy(self, policy: ConsistencyPolicy) -> Self

Sets the consistency policy.

pub fn commit_durability(self, durability: CommitDurability) -> Self

Sets the commit durability.

pub fn env_home(self, path: impl Into<PathBuf>) -> Self

Sets the environment home directory (serves .ndb files for network restore).

pub fn cascade_feeding(self, enabled: bool) -> Self

Enable chained / replica-to-replica log feeding (default false).

When true, a node that becomes a replica also runs a feeder source on its PEER_FEEDER service, serving its OWN WAL to a downstream replica (master → R1 → R2). See RepConfig::cascade_feeding for the JE FeederSource citation and the durability bound.

pub fn quorum_policy(self, policy: QuorumPolicy) -> Self

Sets the quorum policy for elections (default: SimpleMajority).

pub fn phi_threshold(self, threshold: Option<f64>) -> Self

Enable phi accrual failure detection with the given suspicion threshold.

8.0 is the paper’s recommended production value (mistake rate ≈ 10⁻⁸). Call with None to revert to binary heartbeat timeout detection.

pub fn phi_window_size(self, size: usize) -> Self

Sets the phi accrual inter-arrival sample window size (default 200).

pub fn add_initial_peer(self, node: RepNode) -> Self

Add a fully-described initial peer to the group at startup.

pub fn election_phase_timeout(self, timeout: Duration) -> Self

Set the per-peer message timeout for Phase 1 and Phase 2 election exchanges (default: 500 ms).

pub fn reconnect_config(self, config: ReconnectConfig) -> Self

Sets the reconnection backoff configuration for replica partition recovery.

pub fn transport_kind(self, kind: RepTransportKind) -> Self

Sets the wire-level transport this node will use.

Defaults to RepTransportKind::Tcp. RepTransportKind::InMemory for in-process clusters.

pub fn peer_allowlist(self, names: Vec<String>) -> Self

Set the mTLS peer allowlist (Phase 2, v3.1.0).

When non-empty and transport_kind is RepTransportKind::Tls, incoming TLS connections must present a certificate whose Subject CN or DNS SAN matches at least one entry here (case-insensitive, exact match). Connections that fail the check are rejected at the TLS handshake layer.

See RepConfig::peer_allowlist for full details.

pub fn tls_config(self, tls: TlsConfig) -> Self

Set the TLS configuration for the service dispatcher (Phase 3).

When set and transport_kind is RepTransportKind::Tls, crate::replicated_environment::ReplicatedEnvironment will use a TLS-capable service dispatcher that enforces mTLS when peer_allowlist is also non-empty.

See RepConfig::tls_config for full details.

pub fn build(self) -> RepConfig

Builds the RepConfig.

Trait Implementations

impl Clone for RepConfigBuilder

fn clone(&self) -> RepConfigBuilder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RepConfigBuilder

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

Formats the value using the given formatter.