Struct NodeConfig 

pub struct NodeConfig {
    pub node_id: NodeId,
    pub storage_uri: String,
    pub cache_dir: PathBuf,
    pub cores: usize,
    pub memory_bytes: u64,
    pub memory_per_bee: u64,
    pub target_cell_size: u64,
    pub max_cell_size: u64,
    pub min_cell_size: u64,
    pub max_cache_size: u64,
    pub heartbeat_interval: Duration,
    pub dead_threshold: Duration,
}

Configuration for an Apiary node, including auto-detected system capacity.

Fields

node_id: NodeId

Unique identifier for this node.

storage_uri: String

Storage URI: "local://~/.apiary/data" or "s3://bucket/prefix".

cache_dir: PathBuf

Local directory for cell cache and scratch files.

cores: usize

Number of CPU cores (auto-detected).

memory_bytes: u64

Total memory in bytes (auto-detected).

memory_per_bee: u64

Memory budget per bee in bytes (memory_bytes / cores).

target_cell_size: u64

Target cell size in bytes for leafcutter sizing (memory_per_bee / 4).

max_cell_size: u64

Maximum cell size in bytes (target_cell_size * 2).

min_cell_size: u64

Minimum cell size in bytes (floor to amortise S3 overhead).

max_cache_size: u64

Maximum cache size in bytes for local cell storage.

heartbeat_interval: Duration

Interval between heartbeat writes.

dead_threshold: Duration

Duration after which a node with no heartbeat is considered dead.

Implementations

impl NodeConfig

pub fn detect(storage_uri: impl Into<String>) -> Self

Create a new NodeConfig by auto-detecting system resources.

Arguments

• storage_uri — The storage backend URI (e.g., "local://~/.apiary/data" or "s3://bucket/prefix").

Example

use apiary_core::config::NodeConfig;

let config = NodeConfig::detect("local://~/.apiary/data");
assert!(config.cores > 0);
assert!(config.memory_bytes > 0);

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.