fix(gateway): move get_meta to admin API.

Author: Leechael

gateway/rpc/proto/gateway_rpc.proto

@@ -133,8 +133,6 @@ service Gateway {
   rpc RegisterCvm(RegisterCvmRequest) returns (RegisterCvmResponse) {}
   // List all ACME account URIs and the public key history of the certificates for the Content Addressable HTTPS.
   rpc AcmeInfo(google.protobuf.Empty) returns (AcmeInfoResponse) {}
-  // Summary API for inspect.
-  rpc GetMeta(google.protobuf.Empty) returns (GetMetaResponse);
   // Merge state from other Gateway instances.
   rpc UpdateState(GatewayState) returns (google.protobuf.Empty) {}
 }
@@ -157,4 +155,6 @@ service Admin {
   rpc ReloadCert(google.protobuf.Empty) returns (google.protobuf.Empty) {}
   // Set CAA records
   rpc SetCaa(google.protobuf.Empty) returns (google.protobuf.Empty) {}
+  // Summary API for inspect.
+  rpc GetMeta(google.protobuf.Empty) returns (GetMetaResponse) {}
 }

gateway/src/admin_service.rs

@@ -1,9 +1,10 @@
 use std::sync::atomic::Ordering;
+use std::time::{SystemTime, UNIX_EPOCH};
 
 use anyhow::{Context, Result};
 use dstack_gateway_rpc::{
     admin_server::{AdminRpc, AdminServer},
-    GetInfoRequest, GetInfoResponse, HostInfo, RenewCertResponse, StatusResponse,
+    GetInfoRequest, GetInfoResponse, GetMetaResponse, HostInfo, RenewCertResponse, StatusResponse,
 };
 use ra_rpc::{CallContext, RpcCall};
 
@@ -113,6 +114,34 @@ impl AdminRpc for AdminRpcHandler {
             })
         }
     }
+
+    async fn get_meta(self) -> Result<GetMetaResponse> {
+        let state = self.state.lock();
+        let handshakes = state.latest_handshakes(None)?;
+
+        // Total registered instances
+        let registered = state.state.instances.len();
+
+        // Get current timestamp
+        let now = SystemTime::now()
+            .duration_since(UNIX_EPOCH)
+            .context("system time before Unix epoch")?
+            .as_secs();
+
+        // Count online instances (those with handshakes in last 5 minutes)
+        let online = handshakes
+            .values()
+            .filter(|(ts, _)| {
+                // Skip instances that never connected (ts == 0)
+                *ts != 0 && (now - *ts) < 300
+            })
+            .count();
+
+        Ok(GetMetaResponse {
+            registered: registered as u32,
+            online: online as u32,
+        })
+    }
 }
 
 impl RpcCall<Proxy> for AdminRpcHandler {

gateway/src/main_service.rs

@@ -12,7 +12,7 @@ use certbot::{CertBot, WorkDir};
 use cmd_lib::run_cmd as cmd;
 use dstack_gateway_rpc::{
     gateway_server::{GatewayRpc, GatewayServer},
-    AcmeInfoResponse, GatewayState, GetMetaResponse, GuestAgentConfig, RegisterCvmRequest,
+    AcmeInfoResponse, GatewayState, GuestAgentConfig, RegisterCvmRequest,
     RegisterCvmResponse, WireGuardConfig, WireGuardPeer,
 };
 use fs_err as fs;
@@ -691,34 +691,6 @@ impl GatewayRpc for RpcHandler {
         })
     }
 
-    async fn get_meta(self) -> Result<GetMetaResponse> {
-        let state = self.state.lock();
-        let handshakes = state.latest_handshakes(None)?;
-
-        // Total registered instances
-        let registered = state.state.instances.len();
-
-        // Get current timestamp
-        let now = SystemTime::now()
-            .duration_since(UNIX_EPOCH)
-            .context("system time before Unix epoch")?
-            .as_secs();
-
-        // Count online instances (those with handshakes in last 5 minutes)
-        let online = handshakes
-            .values()
-            .filter(|(ts, _)| {
-                // Skip instances that never connected (ts == 0)
-                *ts != 0 && (now - *ts) < 300
-            })
-            .count();
-
-        Ok(GetMetaResponse {
-            registered: registered as u32,
-            online: online as u32,
-        })
-    }
-
     async fn update_state(self, request: GatewayState) -> Result<()> {
         self.ensure_from_gateway()?;
         let mut nodes = vec![];