Struct ReplicationConfig 

pub struct ReplicationConfig {

    pub close_group_size: usize,
    pub quorum_threshold: usize,
    pub paid_list_close_group_size: usize,
    pub neighbor_sync_scope: usize,
    pub neighbor_sync_peer_count: usize,
    pub neighbor_sync_interval_min: Duration,
    pub neighbor_sync_interval_max: Duration,
    pub neighbor_sync_cooldown: Duration,
    pub self_lookup_interval_min: Duration,
    pub self_lookup_interval_max: Duration,
    pub audit_tick_interval_min: Duration,
    pub audit_tick_interval_max: Duration,
    pub audit_response_base: Duration,
    pub audit_response_per_chunk: Duration,
    pub bootstrap_claim_grace_period: Duration,
    pub prune_hysteresis_duration: Duration,
    pub verification_request_timeout: Duration,
    pub fetch_request_timeout: Duration,
    pub bootstrap_complete_timeout_secs: u64,
}

Runtime-configurable replication parameters.

Validated on construction — node rejects invalid configs.

Fields

close_group_size: usize

Close-group width and target holder count per key.

quorum_threshold: usize

Required positive presence votes for quorum.

paid_list_close_group_size: usize

Maximum closest nodes tracking paid status for a key.

neighbor_sync_scope: usize

Number of closest peers to self eligible for neighbor sync.

neighbor_sync_peer_count: usize

Peers synced concurrently per round-robin repair round.

neighbor_sync_interval_min: Duration

Neighbor sync cadence range (min).

neighbor_sync_interval_max: Duration

Neighbor sync cadence range (max).

neighbor_sync_cooldown: Duration

Minimum spacing between successive syncs with the same peer.

self_lookup_interval_min: Duration

Self-lookup cadence range (min).

self_lookup_interval_max: Duration

Self-lookup cadence range (max).

audit_tick_interval_min: Duration

Audit scheduler cadence range (min).

audit_tick_interval_max: Duration

Audit scheduler cadence range (max).

audit_response_base: Duration

Base audit response deadline (chunk-independent component).

audit_response_per_chunk: Duration

Per-chunk allowance added to the base audit response deadline.

bootstrap_claim_grace_period: Duration

Maximum duration a peer may claim bootstrap status.

prune_hysteresis_duration: Duration

Minimum continuous out-of-range duration before pruning a key.

verification_request_timeout: Duration

Verification request timeout (per-batch).

fetch_request_timeout: Duration

Fetch request timeout.

bootstrap_complete_timeout_secs: u64

Seconds to wait for DhtNetworkEvent::BootstrapComplete before proceeding with bootstrap sync (covers bootstrap nodes with no peers).

Implementations

impl ReplicationConfig

pub fn validate(&self) -> Result<(), String>

Validate safety constraints. Returns Err with a description if any constraint is violated.

Errors

Returns a human-readable message describing the first violated constraint.

pub fn quorum_needed(&self, quorum_targets_count: usize) -> usize

Effective quorum votes required for a key given the number of reachable quorum targets.

min(self.quorum_threshold, floor(quorum_targets_count / 2) + 1)

pub fn confirm_needed(paid_group_size: usize) -> usize

Confirmations required for paid-list consensus given the number of peers in the paid-list close group for a key.

floor(paid_group_size / 2) + 1

pub fn random_neighbor_sync_interval(&self) -> Duration

Returns a random duration in [neighbor_sync_interval_min, neighbor_sync_interval_max].

pub fn audit_sample_count(total_keys: usize) -> usize

Compute the number of keys to sample for an audit round, scaled dynamically by the total number of locally stored keys.

Formula: max(floor(sqrt(total_keys)), 1), capped at total_keys.

pub fn max_incoming_audit_keys(stored_chunks: usize) -> usize

Maximum number of keys to accept in an incoming audit challenge.

Scales dynamically: 2 * audit_sample_count(stored_chunks). The 2x margin accounts for the challenger having a larger store than us and therefore sampling more keys.

pub fn audit_response_timeout(&self, chunk_count: usize) -> Duration

Compute the audit response timeout for a challenge with chunk_count keys: base + per_chunk * chunk_count.

pub fn random_audit_tick_interval(&self) -> Duration

Returns a random duration in [audit_tick_interval_min, audit_tick_interval_max].

pub fn random_self_lookup_interval(&self) -> Duration

Returns a random duration in [self_lookup_interval_min, self_lookup_interval_max].

Trait Implementations

impl Clone for ReplicationConfig

fn clone(&self) -> ReplicationConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReplicationConfig

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

Formats the value using the given formatter.

impl Default for ReplicationConfig

fn default() -> Self

Returns the “default value” for a type.