Explorar el Código

Add DialNetDial dial option

Emanuel Evans hace 10 años
padre
commit
3d66ef0760
Se han modificado 1 ficheros con 9 adiciones y 0 borrados
  1. 9 0
      redis/conn.go

+ 9 - 0
redis/conn.go

@@ -97,6 +97,15 @@ func DialConnectTimeout(d time.Duration) DialOption {
 	}}
 }
 
+// DialNetDial specifies a custom dial function for creating TCP
+// connections. If this option is left out, then net.Dial is
+// used. DialNetDial overrides DialConnectTimeout.
+func DialNetDial(dial func(network, addr string) (net.Conn, error)) DialOption {
+	return DialOption{func(do *dialOptions) {
+		do.dial = dial
+	}}
+}
+
 // DialDatabase specifies the database to select when dialing a connection.
 func DialDatabase(db int) DialOption {
 	return DialOption{func(do *dialOptions) {