Remove Port from registry

2019-07-08 08:01:42 +01:00
parent dfffa16590
commit df9fa0c938
1 changed files with 2 additions and 4 deletions
--- a/grpc.go
+++ b/grpc.go
@@ -534,8 +534,7 @@ func (g *grpcServer) Register() error {
 	// register service
 	node := &registry.Node{
 		Id:       config.Name + "-" + config.Id,
-		Address:  addr,
-		Port:     port,
+		Address:  fmt.Sprintf("%s:%d", addr, port),
 		Metadata: config.Metadata,
 	}

@@ -658,8 +657,7 @@ func (g *grpcServer) Deregister() error {

 	node := &registry.Node{
 		Id:      config.Name + "-" + config.Id,
-		Address: addr,
-		Port:    port,
+		Address: fmt.Sprintf("%s:%d", addr, port),
 	}

 	service := &registry.Service{