diff --git a/config/dialer/dialer.go b/config/dialer/dialer.go index a9058195..2b40bdc5 100644 --- a/config/dialer/dialer.go +++ b/config/dialer/dialer.go @@ -1,8 +1,11 @@ package dialer -import "net" +import ( + "context" + "net" +) -type Dialer func(network, address string) (net.Conn, error) +type Dialer func(ctx context.Context, network, address string) (net.Conn, error) type Factory interface { ClusterDialer(clusterName string) (Dialer, error)