From 98ca55ee593c1d073241a295c9aba513e8e96e99 Mon Sep 17 00:00:00 2001 From: tv Date: Wed, 21 Oct 2026 14:51:51 +0200 Subject: rename cluster to swarm everywhere! --- src/main.rs | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) (limited to 'src/main.rs') diff --git a/src/main.rs b/src/main.rs index d9d24f3..ef9bf54 100644 --- a/src/main.rs +++ b/src/main.rs @@ -149,7 +149,7 @@ async fn main() -> Result<()> { doc: Arc::new(RwLock::new(Replica::new(initial_epoch, AutoCommit::new()))), epoch_tx, lifecycle: Arc::new(RwLock::new(NodeLifecycle::Joining { - discovered_cluster_id: None, + discovered_swarm_id: None, })), peer_states: Arc::new(RwLock::new(HashMap::new())), transport: Arc::new(FirewallTransport::new( @@ -194,15 +194,15 @@ async fn main() -> Result<()> { trace!("Peer worker task spawned"); // Switches to committed epochs and catches up with newer ones. Starts before - // bootstrapping: a node joining a compacted cluster can only finish its initial sync + // bootstrapping: a node joining a compacted swarm can only finish its initial sync // after fetching the current epoch from a peer. tokio::spawn(remake::run_worker(state.clone())); trace!("Remake worker task spawned"); tokio::select! { - joined = bootstrap::bootstrap(&state, &seeds) => joined.context("Joining cluster")?, + joined = bootstrap::bootstrap(&state, &seeds) => joined.context("Joining swarm")?, _ = stopped(stop.clone()) => { - info!("Stopped while joining the cluster"); + info!("Stopped while joining the swarm"); return Ok(()); } } @@ -213,7 +213,7 @@ async fn main() -> Result<()> { tokio::spawn(async move { sync::run_change_publisher(publisher_state).await }); info!( - cluster_id = ?state.cluster_id().await, + swarm_id = ?state.swarm_id().await, ready = state.is_ready().await, "Bootstrap completed" ); -- cgit v1.3.1