Merge pull request #219 from linyuyizhipao/master

feat:禁用与启用grpc
douyu · Feb 20, 2021 · 8b67ebe · 8b67ebe
2 parents 78f2392 + bc6d7ad
commit 8b67ebe
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/pkg/registry/etcdv3/registry.go b/pkg/registry/etcdv3/registry.go
@@ -356,7 +356,12 @@ func updateAddrList(al *registry.Endpoints, prefix, scheme string, kvs ...*mvccp
 				xlog.Error("parse uri", xlog.FieldErrKind(ecode.ErrKindUriErr), xlog.FieldErr(err), xlog.FieldKey(string(kv.Key)))
 				continue
 			}
-			al.Nodes[uri.String()] = serviceInfo
+			if serviceInfo.Enable == true {
+				al.Nodes[uri.String()] = serviceInfo
+			} else {
+				delete(al.Nodes, uri.String())
+			}
+
 		case strings.HasPrefix(addr, "configurators/"+scheme):
 			addr = strings.TrimPrefix(addr, "configurators/")