Skip to content

Commit

Permalink
Fix name of discovery
Browse files Browse the repository at this point in the history
  • Loading branch information
brotherlogic committed Jul 23, 2020
1 parent 4e3832f commit 935fba9
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions comms.go
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ import (

// FDialServer dial a specific job
func (s *GoServer) FDialServer(ctx context.Context, servername string) (*grpc.ClientConn, error) {
if servername == "discover" {
if servername == "discovery" {
return s.FDial(fmt.Sprintf("%v:%v", utils.LocalIP, utils.RegistryPort))
}

Expand All @@ -36,7 +36,7 @@ func (s *GoServer) FDialServer(ctx context.Context, servername string) (*grpc.Cl

// FFind finds all servers
func (s *GoServer) FFind(ctx context.Context, servername string) ([]string, error) {
if servername == "discover" {
if servername == "discovery" {
return []string{}, fmt.Errorf("Cannot multi dial discovery")
}

Expand All @@ -62,7 +62,7 @@ func (s *GoServer) FFind(ctx context.Context, servername string) ([]string, erro

// FDialSpecificServer dial a specific job on a specific host
func (s *GoServer) FDialSpecificServer(ctx context.Context, servername string, host string) (*grpc.ClientConn, error) {
if servername == "discover" {
if servername == "discovery" {
return s.FDial(fmt.Sprintf("%v:%v", utils.LocalIP, utils.RegistryPort))
}

Expand Down

0 comments on commit 935fba9

Please sign in to comment.