Node state gossip

Summary: First iteration of gossip protocol to share node state
restatedev · Nov 18, 2024 · d1530ba · d1530ba
1 parent aae0fea
commit d1530ba
Show file tree

Hide file tree

Showing 16 changed files with 677 additions and 375 deletions.
diff --git a/crates/admin/src/cluster_controller/cluster_state_refresher.rs b/crates/admin/src/cluster_controller/cluster_state_refresher.rs
diff --git a/crates/admin/src/cluster_controller/grpc_svc_handler.rs b/crates/admin/src/cluster_controller/grpc_svc_handler.rs
@@ -80,7 +80,7 @@ impl ClusterCtrlSvc for ClusterCtrlSvcHandler {
             .map_err(|_| Status::aborted("Node is shutting down"))?;
 
         let resp = ClusterStateResponse {
-            cluster_state: Some((*cluster_state).clone().into()),
+            cluster_state: Some(cluster_state.into()),
         };
         Ok(Response::new(resp))
     }

diff --git a/crates/admin/src/cluster_controller/mod.rs b/crates/admin/src/cluster_controller/mod.rs
@@ -8,7 +8,6 @@
 // the Business Source License, use of this software will be governed
 // by the Apache License, Version 2.0.
 
-pub mod cluster_state_refresher;
 pub mod grpc_svc_handler;
 mod logs_controller;
 mod observed_cluster_state;