diff --git a/client/grpc/grpc.go b/client/grpc/grpc.go index 542c9173..e3ada840 100644 --- a/client/grpc/grpc.go +++ b/client/grpc/grpc.go @@ -189,6 +189,7 @@ func (g *grpcClient) stream(ctx context.Context, node *registry.Node, req client grpcDialOptions := []grpc.DialOption{ grpc.WithDefaultCallOptions(grpc.ForceCodec(wc)), + grpc.WithTimeout(opts.DialTimeout), g.secure(), }