- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 41 for Dial (0.17 sec)
-
internal/http/dial_dnscache.go
// function. LookupHost may implement an internal DNS caching implementation, lookupHost // input if nil then net.DefaultResolver.LookupHost is used. // // It dials one by one and returns first connected `net.Conn`. // If it fails to dial all IPs from cache it returns first error. If no baseDialFunc // is given, it sets default dial function. //
Go - Registered: Sun Apr 07 19:28:10 GMT 2024 - Last Modified: Mon Jul 03 19:30:51 GMT 2023 - 2.6K bytes - Viewed (0) -
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 setups a custom dialer for internode communication
Go - Registered: Sun Apr 07 19:28:10 GMT 2024 - Last Modified: Wed May 03 21:12:25 GMT 2023 - 1.7K 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 Apr 07 19:28:10 GMT 2024 - Last Modified: Wed Jun 07 16:53:05 GMT 2023 - 4.4K bytes - Viewed (2) -
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 Apr 14 19:28:10 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 Apr 17 22:53:10 GMT 2024 - Last Modified: Tue Dec 19 22:42:42 GMT 2023 - 3.7K 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 Apr 17 22:53:10 GMT 2024 - Last Modified: Thu Feb 08 21:58:32 GMT 2024 - 1.4K bytes - Viewed (0) -
docs/metrics/v3.md
| `minio_system_network_internode_dial_errors_total` | `counter` | Total number of internode TCP dial timeouts and errors | `server,pool_index` | | `minio_system_network_internode_dial_avg_time_nanos` | `gauge` | Average dial time of internodes TCP calls in nanoseconds | `server,pool_index` |
Plain Text - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Thu Apr 11 21:22:15 GMT 2024 - 19K 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 Apr 07 19:28:10 GMT 2024 - Last Modified: Tue Mar 19 04:37:54 GMT 2024 - 9.1K 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 Apr 17 22:53:10 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 2.4K bytes - Viewed (0) -
internal/event/target/amqp.go
} return ch, nil, nil } if !isAMQPClosedErr(err) { return nil, nil, err } // close when we know this is a network error. target.conn.Close() } conn, err = amqp091.Dial(target.args.URL.String()) if err != nil { if xnet.IsConnRefusedErr(err) { return nil, nil, store.ErrNotConnected } return nil, nil, err } ch, err = conn.Channel() if err != nil {
Go - Registered: Sun Apr 07 19:28:10 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 10K bytes - Viewed (0)