diff --git a/clustering/agent.go b/clustering/agent.go index 39d95a79..2be20ffe 100644 --- a/clustering/agent.go +++ b/clustering/agent.go @@ -60,16 +60,10 @@ func (f defaultAgentFactory) New(ctx context.Context, cluster *mocov1beta2.MySQL Time: 1 * time.Minute, } cred := credentials.NewTLS(f.reloader.TLSClientConfig()) - /* - "grpc.WithBlock() DialOption" is deleted in NewClient - Please see, https://pkg.go.dev/google.golang.org/grpc#WithBlock - this DialOption is not supported by NewClient. Will be supported throughout 1.x. - */ conn, err := grpc.NewClient(addr, grpc.WithAuthority(cluster.PodHostname(index)), grpc.WithTransportCredentials(cred), grpc.WithKeepaliveParams(kp)) - if err != nil { return agentConn{}, err }