Struct NodeConfig 

pub struct NodeConfig {
    pub bind_addr: String,
    pub node_id: u64,
    pub peers: Vec<String>,
    pub heartbeat_interval_ms: u64,
    pub election_timeout_ms: u64,
    pub compaction_threshold: usize,
    pub data_dir: Option<PathBuf>,
    pub metrics_addr: String,
    pub key_rotation_interval_secs: Option<u64>,
    pub key_retention_count: usize,
}

Full cluster node configuration.

Can be loaded from a TOML file with NodeConfig::load or from a TOML string with NodeConfig::from_toml. After loading, call NodeConfig::apply_env_overrides to layer environment variable overrides on top.

Field restart requirements

Field	Hot-reloadable
heartbeat_interval_ms	Yes (via DynamicConfig)
compaction_threshold	Yes (via DynamicConfig)
All other fields	No — requires restart

Fields

bind_addr: String

Bind address for Raft RPC server (e.g. "0.0.0.0:7001").

node_id: u64

Node ID — must be unique across the cluster and > 0.

peers: Vec<String>

Peer addresses as "node_id=addr" strings, e.g. ["2=10.0.0.2:7001"].

heartbeat_interval_ms: u64

Raft heartbeat interval in milliseconds (default 150).

Hot-reloadable.

election_timeout_ms: u64

Raft election timeout in milliseconds (default 300).

Must be >= 2 * heartbeat_interval_ms. Requires restart to change.

compaction_threshold: usize

Log compaction threshold: number of entries before triggering a snapshot (default 10 000).

Hot-reloadable.

data_dir: Option<PathBuf>

Data directory for Raft log persistence. None disables persistence.

metrics_addr: String

Metrics HTTP endpoint address (default "0.0.0.0:9091").

Requires restart to change.

key_rotation_interval_secs: Option<u64>

Optional automatic-rotation interval for the log-encryption master key, in seconds. None disables time-based rotation; rotation can still be triggered manually via crate::key_rotation::KeyManager::rotate.

The background tokio task that drives time-based rotation is deferred to a future cycle; this field reserves the configuration surface for when it lands.

key_retention_count: usize

Number of crate::key_rotation::KeyVersions the crate::key_rotation::KeyManager retains in its history (current and previous keys). Default 3. Lower values reclaim memory faster at the cost of decrypting fewer historical entries after rotation.

Implementations

impl NodeConfig

pub fn load(path: &Path) -> Result<Self, ConfigError>

Load from a TOML file, then layer environment variable overrides.

Env vars override individual fields:

Env var	Field
AMATERS_BIND_ADDR	bind_addr
AMATERS_NODE_ID	node_id
AMATERS_PEERS	peers (comma-separated id=addr pairs)
AMATERS_HEARTBEAT_INTERVAL_MS	heartbeat_interval_ms
AMATERS_ELECTION_TIMEOUT_MS	election_timeout_ms
AMATERS_COMPACTION_THRESHOLD	compaction_threshold
AMATERS_DATA_DIR	data_dir
AMATERS_METRICS_ADDR	metrics_addr

pub fn from_toml(toml_str: &str) -> Result<Self, ConfigError>

Parse from a TOML string directly.

Useful in tests and when the configuration is provided via a secret store rather than a file on disk. Does not apply env overrides; call apply_env_overrides if you also want those.

pub fn apply_env_overrides(&mut self)

Apply environment variable overrides from the current process environment.

Unset variables leave the corresponding field unchanged.

pub fn dynamic(&self) -> DynamicConfig

Extract the hot-reloadable subset of this configuration.

The returned DynamicConfig can be stored in an Arc<parking_lot::RwLock<DynamicConfig>> and updated in place when the configuration is reloaded (e.g. on SIGHUP or via an admin RPC) without restarting the node.

pub fn validate(&self) -> Vec<ConfigError>

Validate configuration fields.

Returns a list of ConfigError::Validation variants describing each detected problem. An empty return value means the configuration is valid.

Trait Implementations

impl Clone for NodeConfig

fn clone(&self) -> NodeConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NodeConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for NodeConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for NodeConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.