- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 156 for Dialer (0.11 sec)
-
pkg/hbone/dialer.go
return nil } // TLSDialWithDialer is an implementation of tls.DialWithDialer that accepts a generic Dialer func TLSDialWithDialer(dialer Dialer, network, addr string, config *tls.Config) (*tls.Conn, error) { return tlsDial(context.Background(), dialer, network, addr, config) } func tlsDial(ctx context.Context, netDialer Dialer, network, addr string, config *tls.Config) (*tls.Conn, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 15:56:41 UTC 2023 - 5.1K bytes - Viewed (0) -
pkg/test/echo/common/dialer.go
return client.Do(req) } // DefaultTCPDialFunc just calls dialer.Dial, with no alterations to the arguments. DefaultTCPDialFunc = func(dialer net.Dialer, ctx context.Context, address string) (net.Conn, error) { return dialer.DialContext(ctx, "tcp", address) } // DefaultDialer is provides defaults for all dial functions. DefaultDialer = Dialer{ GRPC: DefaultGRPCDialFunc, Websocket: DefaultWebsocketDialFunc,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Aug 07 15:55:42 UTC 2020 - 3K bytes - Viewed (0) -
src/net/http/transport_default_other.go
// license that can be found in the LICENSE file. //go:build !wasm package http import ( "context" "net" ) func defaultTransportDialContext(dialer *net.Dialer) func(context.Context, string, string) (net.Conn, error) { return dialer.DialContext
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 11 20:54:10 UTC 2023 - 362 bytes - Viewed (0) -
internal/http/dial_others.go
// NewInternodeDialContext configures a custom dialer for internode communications func NewInternodeDialContext(dialTimeout time.Duration, _ TCPOptions) DialContext { return func(ctx context.Context, network, addr string) (net.Conn, error) { dialer := &net.Dialer{ Timeout: dialTimeout, } return dialer.DialContext(ctx, network, addr) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Apr 24 04:08:47 UTC 2024 - 1.6K bytes - Viewed (0) -
internal/grid/connection_test.go
"github.com/minio/minio/internal/logger/target/testlogger" ) func TestDisconnect(t *testing.T) { defer testlogger.T.SetLogTB(t)() defer timeout(10 * time.Second)() hosts, listeners, _ := getHosts(2) dialer := &net.Dialer{ Timeout: 1 * time.Second, } errFatal := func(err error) { t.Helper() if err != nil { t.Fatal(err) } } wrapServer := func(handler http.Handler) http.Handler {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/proxy/dial.go
dialAddr := netutil.CanonicalAddr(url) dialer, err := utilnet.DialerFor(transport) if err != nil { klog.V(5).Infof("Unable to unwrap transport %T to get dialer: %v", transport, err) } switch url.Scheme { case "http": if dialer != nil { return dialer(ctx, "tcp", dialAddr) } var d net.Dialer return d.DialContext(ctx, "tcp", dialAddr) case "https":
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 23 22:33:38 UTC 2023 - 3.8K bytes - Viewed (0) -
pkg/probe/dialer_windows.go
// Ref: https://issues.k8s.io/89898 func ProbeDialer() *net.Dialer { dialer := &net.Dialer{ Control: func(network, address string, c syscall.RawConn) error { return c.Control(func(fd uintptr) { syscall.SetsockoptLinger(syscall.Handle(fd), syscall.SOL_SOCKET, syscall.SO_LINGER, &syscall.Linger{Onoff: 1, Linger: 1}) }) }, } return dialer
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 22 16:57:32 UTC 2023 - 1.4K bytes - Viewed (0) -
pkg/probe/dialer_others.go
// Ref: https://issues.k8s.io/89898 func ProbeDialer() *net.Dialer { dialer := &net.Dialer{ Control: func(network, address string, c syscall.RawConn) error { return c.Control(func(fd uintptr) { syscall.SetsockoptLinger(int(fd), syscall.SOL_SOCKET, syscall.SO_LINGER, &syscall.Linger{Onoff: 1, Linger: 1}) }) }, } return dialer
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 22 16:57:32 UTC 2023 - 1.4K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/dialer_others.go
// Ref: https://issues.k8s.io/89898 func ProbeDialer() *net.Dialer { dialer := &net.Dialer{ Control: func(network, address string, c syscall.RawConn) error { return c.Control(func(fd uintptr) { _ = syscall.SetsockoptLinger(int(fd), syscall.SOL_SOCKET, syscall.SO_LINGER, &syscall.Linger{Onoff: 1, Linger: 1}) }) }, } return dialer
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Jan 28 02:39:05 UTC 2023 - 1.5K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/dialer_windows.go
// Ref: https://issues.k8s.io/89898 func ProbeDialer() *net.Dialer { dialer := &net.Dialer{ Control: func(network, address string, c syscall.RawConn) error { return c.Control(func(fd uintptr) { syscall.SetsockoptLinger(syscall.Handle(fd), syscall.SOL_SOCKET, syscall.SO_LINGER, &syscall.Linger{Onoff: 1, Linger: 1}) }) }, } return dialer
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Jan 28 02:39:05 UTC 2023 - 1.5K bytes - Viewed (0)