rename cluster to swarm everywhere!

1 files changed, 5 insertions, 5 deletions

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"
     );