- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 300 for Dialer (0.1 sec)
-
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) -
api/go1.15.txt
pkg crypto/tls, type Config struct, VerifyConnection func(ConnectionState) error pkg crypto/tls, type Dialer struct pkg crypto/tls, type Dialer struct, Config *Config pkg crypto/tls, type Dialer struct, NetDialer *net.Dialer pkg crypto/x509, func CreateRevocationList(io.Reader, *RevocationList, *Certificate, crypto.Signer) ([]uint8, error) pkg crypto/x509, type RevocationList struct
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jul 17 02:15:01 UTC 2020 - 7.6K bytes - Viewed (0) -
internal/http/dial_linux.go
// NewInternodeDialContext setups a custom dialer for internode communication func NewInternodeDialContext(dialTimeout time.Duration, opts TCPOptions) DialContext { return func(ctx context.Context, network, addr string) (net.Conn, error) { dialer := &net.Dialer{ Timeout: dialTimeout, Control: setTCPParametersFn(opts), } conn, err := dialer.DialContext(ctx, network, addr) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 4.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/egressselector/egress_selector_test.go
}, } for _, tc := range testcases { t.Run(tc.name, func(t *testing.T) { // Setup the various pieces such as the fake dialer prior to initializing the egress selector. // Go doesn't allow function pointer comparison, nor does its reflect package // So overriding the default dialer to detect if it is returned. fake := &fakeEgressSelection{} directDialer = fake.fakeDirectDialer cs, err := NewEgressSelector(tc.input)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 26 22:41:29 UTC 2023 - 12.3K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/websocket.go
dialContext = func(network, addr string) (net.Conn, error) { return newDialer(cfg).Dial("unix", cfg.UDS) } } dialer := &websocket.Dialer{ TLSClientConfig: cfg.tlsConfig, NetDial: dialContext, HandshakeTimeout: cfg.timeout, } conn, _, err := dialer.Dial(req.Url, wsReq) if err != nil { // timeout or bad handshake return outBuffer.String(), err } defer func() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 11 16:27:16 UTC 2022 - 3.3K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/util.go
return dialer.(hbone.Dialer) } out := &net.Dialer{ Timeout: common.ConnectionTimeout, } if cfg.forceDNSLookup { out.Resolver = newResolver(common.ConnectionTimeout, "", "") } return out } func newResolver(timeout time.Duration, protocol, dnsServer string) *net.Resolver { return &net.Resolver{ PreferGo: true, Dial: func(ctx context.Context, network, address string) (net.Conn, error) { d := net.Dialer{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Oct 08 09:39:20 UTC 2023 - 4.4K bytes - Viewed (0) -
src/net/tcpsock_unix_test.go
defer wg.Done() time.Sleep(time.Duration(rand.Int63n(int64(5 * time.Millisecond)))) cancel() }() go func(i int) { defer wg.Done() var dialer Dialer // Try to connect to a real host on a port // that it is not listening on. _, err := dialer.DialContext(ctx, "tcp", "golang.org:3") if err == nil { t.Errorf("Dial to unbound port succeeded on attempt %d", i) } <-sem }(i) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 2.3K bytes - Viewed (0) -
pkg/kubelet/apis/podresources/client.go
addr, dialer, err := util.GetAddressAndDialer(socket) if err != nil { return nil, nil, err } ctx, cancel := context.WithTimeout(context.Background(), connectionTimeout) defer cancel() conn, err := grpc.DialContext(ctx, addr, grpc.WithTransportCredentials(insecure.NewCredentials()), grpc.WithContextDialer(dialer),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 2.5K bytes - Viewed (0) -
src/net/http/transport_default_wasm.go
// license that can be found in the LICENSE file. //go:build (js && wasm) || wasip1 package http import ( "context" "net" ) func defaultTransportDialContext(dialer *net.Dialer) func(context.Context, string, string) (net.Conn, error) { return nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 11 20:54:10 UTC 2023 - 364 bytes - Viewed (0)