Function init_cluster

nodedb/src/control/cluster/init.rs:21–49

Initialize the cluster: create transport, open catalog, bootstrap/join/restart. Returns the cluster handle; the caller must then call [`super::start_raft::start_raft`] after `SharedState` is constructed so the applier has the dispatcher / WAL it needs.

(
    config: &ClusterSettings,
    data_dir: &std::path::Path,
    transport_tuning: &ClusterTransportTuning,
)

/// [`super::start_raft::start_raft`] after `SharedState` is constructed
/// so the applier has the dispatcher / WAL it needs.
pub async fn init_cluster(
    config: &ClusterSettings,
    data_dir: &std::path::Path,
    transport_tuning: &ClusterTransportTuning,
) -> crate::Result<ClusterHandle> {
    // 1a. Resolve TLS credentials (mandatory mTLS unless explicitly opted out).
    let credentials = crate::control::cluster::tls::resolve_credentials(config, data_dir)?;

    // 1b. Create QUIC transport, configured from ClusterTransportTuning.
    let transport = Arc::new(
        nodedb_cluster::NexarTransport::with_tuning(
            config.node_id,
            config.listen,
            transport_tuning,
            credentials,
        )
        .map_err(|e| crate::Error::Config {
            detail: format!("cluster transport: {e}"),
        })?,
    );

    info!(
        node_id = config.node_id,
        addr = %transport.local_addr(),
        "cluster QUIC transport bound"
    );

    init_cluster_with_transport(config, transport, data_dir, transport_tuning).await
}

/// Initialize the cluster using a pre-bound QUIC transport.
///