Update getState

jd-opensource · Jan 17, 2025 · cc6b2b6 · cc6b2b6
1 parent 548bd94
commit cc6b2b6
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/...router-grpc/src/main/java/com/jd/live/agent/plugin/router/gprc/instance/GrpcEndpoint.java b/...router-grpc/src/main/java/com/jd/live/agent/plugin/router/gprc/instance/GrpcEndpoint.java
@@ -48,7 +48,17 @@ public String getLabel(String key) {
 
     @Override
     public EndpointState getState() {
-        return EndpointState.HEALTHY;
+        switch (getConnectivityState()) {
+            case READY:
+                return EndpointState.HEALTHY;
+            case IDLE:
+            case CONNECTING:
+            case TRANSIENT_FAILURE:
+                return EndpointState.DISABLE;
+            case SHUTDOWN:
+            default:
+                return EndpointState.CLOSING;
+        }
     }
 
     public Subchannel getSubchannel() {