src/server/worker/client.go
func NewClient(address string) (Client, error) {
	port, err := strconv.Atoi(os.Getenv(client.PPSWorkerPortEnv))
	if err != nil {
		return Client{}, err
	}
	conn, err := grpc.Dial(fmt.Sprintf("%s:%d", address, port),
		append(client.DefaultDialOptions(), grpc.WithInsecure())...)
	if err != nil {
		return Client{}, err
	}
	return newClient(conn), nil
}
func NewClient(address string) (Client, error) {
	port, err := strconv.Atoi(os.Getenv(client.PPSWorkerPortEnv))
	if err != nil {
		return Client{}, err
	}
	conn, err := grpc.Dial(fmt.Sprintf("%s:%d", address, port),
		append(client.DefaultDialOptions(), grpc.WithInsecure())...)
	if err != nil {
		return Client{}, err
	}
	return newClient(conn), nil
}
func NewClient ( address string ) ( Client , error ) { port , err := strconv . Atoi ( os . Getenv ( client . PPSWorkerPortEnv ) ) if err != nil { return Client { } , err } conn , err := grpc . Dial ( fmt . Sprintf ( " " , address , port ) , append ( client . DefaultDialOptions ( ) , grpc . WithInsecure ( ) ) ... ) if err != nil { return Client { } , err } return newClient ( conn ) , nil }
// NewClient returns a worker client for the worker at the IP address passed in.
NewClient returns a worker client for the worker at the IP address passed in .