- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for Dial (0.14 sec)
-
internal/http/dial_others.go
func setTCPParametersFn(opts TCPOptions) func(network, address string, c syscall.RawConn) error { return func(network, address string, c syscall.RawConn) error { return nil } } // DialContext is a function to make custom Dial for internode communications type DialContext func(ctx context.Context, network, address string) (net.Conn, error) // NewInternodeDialContext configures a custom dialer for internode communications
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 1.6K bytes - Viewed (0) -
internal/http/dial_linux.go
_ = syscall.SetsockoptString(fd, syscall.SOL_SOCKET, syscall.SO_BINDTODEVICE, opts.Interface) } } }) return nil } } // DialContext is a function to make custom Dial for internode communications type DialContext func(ctx context.Context, network, address string) (net.Conn, error) // NewInternodeDialContext setups a custom dialer for internode communication
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 4.3K bytes - Viewed (3) -
cmd/metrics-v3-system-network.go
package cmd import ( "context" "github.com/minio/minio/internal/rest" ) const ( internodeErrorsTotal MetricName = "errors_total" internodeDialErrorsTotal MetricName = "dial_errors_total" internodeDialAvgTimeNanos MetricName = "dial_avg_time_nanos" internodeSentBytesTotal MetricName = "sent_bytes_total" internodeRecvBytesTotal MetricName = "recv_bytes_total" ) var (
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 2.4K bytes - Viewed (0) -
istioctl/pkg/xds/client.go
if err != nil { return nil, fmt.Errorf("could not dial: %w", err) } err = adscConn.Run() if err != nil { return nil, fmt.Errorf("ADSC: failed running %v", err) } err = adscConn.Send(dr) if err != nil { return nil, err } response, err := adscConn.WaitVersion(opts.Timeout, dr.TypeUrl, "") return response, err } // DialOptions constructs gRPC dial options from command line configuration
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Dec 19 22:42:42 GMT 2023 - 3.7K bytes - Viewed (0) -
internal/event/target/redis.go
return nil, fmt.Errorf("unable to initialize the queue store of Redis `%s`: %w", id, err) } } pool := &redis.Pool{ MaxIdle: 3, IdleTimeout: 2 * 60 * time.Second, Dial: func() (redis.Conn, error) { conn, err := redis.Dial("tcp", args.Addr.String()) if err != nil { return nil, err } if args.Password != "" { if args.User != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 9.1K bytes - Viewed (0) -
cni/pkg/pluginlistener/listener_test.go
var d net.Dialer return d.DialContext(ctx, "unix", socket) })) conn, err := grpc.Dial(socket, opts...) if err != nil { return nil, err } return conn, nil
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 21:58:32 GMT 2024 - 1.4K bytes - Viewed (0) -
cni/pkg/plugin/cnieventclient.go
url string } func buildClient(address, path string) CNIEventClient { c := &http.Client{ Transport: &http.Transport{ DialContext: func(_ context.Context, _, _ string) (net.Conn, error) { return net.Dial("unix", address) }, }, Timeout: 1000 * time.Millisecond, } eventC := CNIEventClient{ client: c, url: "http://unix" + path, } return eventC }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 2.4K bytes - Viewed (0) -
internal/grid/manager.go
// No connection to local. continue } m.targets[host] = newConnection(connectionParams{ ctx: ctx, id: m.ID, local: o.Local, remote: host, dial: o.Dialer, handlers: &m.handlers, auth: o.AddAuth, blockConnect: o.BlockConnect, tlsConfig: o.TLSConfig, publisher: o.TraceTo, incomingBytes: o.Incoming,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0)