Skip to content

Commit

Permalink
address the comment
Browse files Browse the repository at this point in the history
Signed-off-by: Ryan Leung <[email protected]>
  • Loading branch information
rleungx committed Aug 12, 2024
1 parent 01372dc commit 059b18e
Show file tree
Hide file tree
Showing 5 changed files with 2 additions and 4 deletions.
1 change: 0 additions & 1 deletion pkg/mcs/resourcemanager/server/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -113,7 +113,6 @@ func (s *Server) Run() (err error) {
return err
}

// register
if s.clusterID, s.serviceID, s.serviceRegister, err = utils.Register(s, constant.ResourceManagerServiceName); err != nil {
return err
}
Expand Down
1 change: 0 additions & 1 deletion pkg/mcs/scheduling/server/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -149,7 +149,6 @@ func (s *Server) Run() (err error) {
return err
}

// register
if s.clusterID, s.serviceID, s.serviceRegister, err = utils.Register(s, constant.SchedulingServiceName); err != nil {
return err
}
Expand Down
2 changes: 1 addition & 1 deletion pkg/mcs/server/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -100,7 +100,7 @@ func (bs *BaseServer) SetEtcdClient(etcdClient *clientv3.Client) {
bs.etcdClient = etcdClient
}

// SetETCDClient sets the etcd client.
// GetEtcdClient returns the etcd client.
func (bs *BaseServer) GetEtcdClient() *clientv3.Client {
return bs.etcdClient
}
Expand Down
1 change: 0 additions & 1 deletion pkg/mcs/tso/server/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -156,7 +156,6 @@ func (s *Server) Run() (err error) {
return err
}

// register
if s.clusterID, s.serviceID, s.serviceRegister, err = utils.Register(s, constant.TSOServiceName); err != nil {
return err
}
Expand Down
1 change: 1 addition & 0 deletions pkg/mcs/utils/util.go
Original file line number Diff line number Diff line change
Expand Up @@ -278,6 +278,7 @@ func StopGRPCServer(s server) {
}
}

// Register registers the service.
func Register(s server, serviceName string) (uint64, *discovery.ServiceRegistryEntry, *discovery.ServiceRegister, error) {
var (
clusterID uint64
Expand Down

0 comments on commit 059b18e

Please sign in to comment.