pr resolves +2=2

examples/raft-kv-memstore-grpc/build.rs

@@ -1,12 +1,14 @@
 fn main() -> Result<(), Box<dyn std::error::Error>> {
     println!("cargo:rerun-if-changed=src/*");
-    tonic_build::configure().compile_protos(
-        &[
-            "proto/internal_service.proto",
-            "proto/management_service.proto",
-            "proto/api_service.proto",
-        ],
-        &["proto"],
-    )?;
+    tonic_build::configure()
+        .type_attribute("openraftpb.Node", "#[derive(Eq, serde::Serialize, serde::Deserialize)]")
+        .compile_protos(
+            &[
+                "proto/internal_service.proto",
+                "proto/management_service.proto",
+                "proto/api_service.proto",
+            ],
+            &["proto"],
+        )?;
     Ok(())
 }

examples/raft-kv-memstore-grpc/proto/management_service.proto

@@ -18,34 +18,33 @@ service ManagementService {
 
 // InitRequest contains the initial set of nodes for cluster initialization
 message InitRequest {
-  repeated Node nodes = 1;  // List of initial cluster nodes
+  repeated Node nodes = 1; // List of initial cluster nodes
 }
 
 // Node represents a single node in the Raft cluster
 message Node {
-  string rpc_addr = 1;  // RPC address for node communication
-  uint64 node_id = 2;   // Unique identifier for the node
+  string rpc_addr = 1; // RPC address for node communication
+  uint64 node_id = 2;  // Unique identifier for the node
 }
 
 // AddLearnerRequest specifies parameters for adding a learner node
 message AddLearnerRequest {
-  Node node = 1;      // Node to be added as a learner
-  bool blocking = 2;  // Whether to wait for the operation to complete
+  Node node = 1; // Node to be added as a learner
 }
 
 // RaftRequestString represents a string-based Raft request
 message RaftRequestString {
-  string data = 1;  // Request data in string format
+  string data = 1; // Request data in string format
 }
 
 // RaftReplyString represents a string-based Raft response
 message RaftReplyString {
-  string data = 1;   // Response data
-  string error = 2;  // Error message, if any
+  string data = 1;  // Response data
+  string error = 2; // Error message, if any
 }
 
 // ChangeMembershipRequest specifies parameters for modifying cluster membership
 message ChangeMembershipRequest {
-  repeated uint64 members = 1;  // New set of member node IDs
+  repeated uint64 members = 1; // New set of member node IDs
   bool retain = 2;             // Whether to retain existing configuration
 }

examples/raft-kv-memstore-grpc/src/grpc/management_service.rs

@@ -107,7 +107,7 @@ impl ManagementService for ManagementServiceImpl {
 
         let result = self
             .raft_node
-            .add_learner(node.node_id, raft_node, req.blocking)
+            .add_learner(node.node_id, raft_node, true)
             .await
             .map_err(|e| Status::internal(format!("Failed to add learner node: {}", e)))?;
 

examples/raft-kv-memstore-grpc/src/lib.rs

@@ -1,7 +1,6 @@
 #![allow(clippy::uninlined_format_args)]
 
-use std::fmt::Display;
-
+use crate::protobuf::Node;
 use crate::store::Request;
 use crate::store::Response;
 
@@ -25,18 +24,6 @@ pub type LogStore = store::LogStore;
 pub type StateMachineStore = store::StateMachineStore;
 pub type Raft = openraft::Raft<TypeConfig>;
 
-#[derive(Debug, Clone, serde::Serialize, serde::Deserialize, PartialEq, Eq, Default)]
-pub struct Node {
-    pub node_id: u64,
-    pub rpc_addr: String,
-}
-
-impl Display for Node {
-    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
-        write!(f, "Node {{ rpc_addr: {}, node_id: {} }}", self.rpc_addr, self.node_id)
-    }
-}
-
 pub mod protobuf {
     tonic::include_proto!("openraftpb");
 }