完成注册中心服务实例增加注册到系统的时间字段后端开发 #177

nacos-group · Dec 2, 2024 · 0b64b92 · 0b64b92
1 parent 2cc8d1f
commit 0b64b92
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 1 deletion.
diff --git a/src/grpc/handler/naming_batch_instance.rs b/src/grpc/handler/naming_batch_instance.rs
@@ -85,6 +85,7 @@ impl BatchInstanceRequestHandler {
                     group_service: Default::default(),
                     metadata: input.metadata.unwrap_or_default(),
                     last_modified_millis: last_modified_millis.to_owned(),
+                    register_time: last_modified_millis,
                     namespace_id: namesapce_id.clone(),
                     app_name: "".to_owned(),
                     from_grpc: true,

diff --git a/src/grpc/handler/naming_instance.rs b/src/grpc/handler/naming_instance.rs
@@ -62,6 +62,7 @@ impl InstanceRequestHandler {
             } else {
                 return Err(anyhow::format_err!("serivceName is unvaild!"));
             };
+            let now = now_millis_i64();
             let mut instance = Instance {
                 id: Default::default(),
                 ip: input.ip.unwrap(),
@@ -75,7 +76,8 @@ impl InstanceRequestHandler {
                 group_name,
                 group_service: Default::default(),
                 metadata: input.metadata.unwrap_or_default(),
-                last_modified_millis: now_millis_i64(),
+                last_modified_millis: now,
+                register_time: now,
                 namespace_id: Arc::new(NamingUtils::default_namespace(
                     request.namespace.unwrap_or_default(),
                 )),

diff --git a/src/naming/model.rs b/src/naming/model.rs
@@ -20,6 +20,7 @@ pub struct Instance {
     pub group_service: Arc<String>,
     pub metadata: Arc<HashMap<String, String>>,
     pub last_modified_millis: i64,
+    pub register_time: i64,
     pub namespace_id: Arc<String>,
     pub app_name: String,
     pub from_grpc: bool,
@@ -124,6 +125,7 @@ impl Default for Instance {
             group_service: Default::default(),
             metadata: Default::default(),
             last_modified_millis: Default::default(),
+            register_time: now_millis_i64(),
             namespace_id: Default::default(),
             app_name: Default::default(),
             from_grpc: false,

diff --git a/src/naming/service.rs b/src/naming/service.rs
@@ -85,6 +85,7 @@ impl Service {
         let old_instance = self.instances.get(&key);
         let mut replace_old_client_id = None;
         if let Some(old_instance) = old_instance {
+            instance.register_time = old_instance.register_time;
             if !instance.from_grpc && old_instance.from_grpc {
                 /*
                 match (old_instance.from_grpc, old_instance.is_from_cluster()) {