- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for Dial (0.15 sec)
-
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 28 19:28:10 GMT 2024 - Last Modified: Sat Oct 07 15:07:38 GMT 2023 - 10K 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 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 16:07:23 GMT 2024 - 26K bytes - Viewed (0) -
internal/grid/connection.go
StateShutdown // MaxDeadline is the maximum deadline allowed, // Approx 49 days. MaxDeadline = time.Duration(math.MaxUint32) * time.Millisecond ) // ContextDialer is a dialer that can be used to dial a remote. type ContextDialer func(ctx context.Context, network, address string) (net.Conn, error) // DialContext implements the Dialer interface.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
docs/metrics/prometheus/list.md
|:------------------------------------------|:--------------------------------------------------------| | `minio_inter_node_traffic_dial_avg_time` | Average time of internodes TCP dial calls. | | `minio_inter_node_traffic_dial_errors` | Total number of internode TCP dial timeouts and errors. | | `minio_inter_node_traffic_errors_total` | Total number of failed internode calls. |
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 43.4K bytes - Viewed (2) -
internal/http/listener_test.go
continue nextTest } t.Fatalf("Test %d: error: expected = <nil>, got = %v", i+1, err) } } for _, serverAddr := range listener.Addrs() { conn, err := net.Dial("tcp", serverAddr.String()) if err != nil { t.Fatalf("Test %d: error: expected = <nil>, got = %v", i+1, err) } conn.Close() } listener.Close() } }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Jun 12 16:09:28 GMT 2023 - 11.8K bytes - Viewed (0) -
api/go1.9.txt
pkg net, method (*TCPConn) SyscallConn() (syscall.RawConn, error) pkg net, method (*UDPConn) SyscallConn() (syscall.RawConn, error) pkg net, method (*UnixConn) SyscallConn() (syscall.RawConn, error) pkg net, type Resolver struct, Dial func(context.Context, string, string) (Conn, error) pkg net, type Resolver struct, StrictErrors bool pkg net/http, func ServeTLS(net.Listener, Handler, string, string) error pkg net/http, method (*Server) RegisterOnShutdown(func())
Plain Text - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Oct 04 20:20:20 GMT 2021 - 10.7K bytes - Viewed (0) -
common/config/.golangci.yml
# This is not helpful. The new function is not very usable and the current function will not be removed - linters: - staticcheck text: 'SA1019: grpc.Dial is deprecated: use NewClient instead' - linters: - staticcheck text: 'SA1019: grpc.DialContext is deprecated: use NewClient instead' # Independently from option `exclude` we use default exclude patterns,
Others - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Apr 22 19:22:39 GMT 2024 - 11K bytes - Viewed (0) -
misc/ios/go_ios_exec.go
} else { errChan <- fmt.Errorf("idevicedebugserverproxy: %v", err) } } errChan <- nil }() closer := func() { cmd.Process.Kill() <-errChan } // Dial localhost:3222 to ensure the proxy is ready. delay := time.Second / 4 for attempt := 0; attempt < 5; attempt++ { conn, err := net.DialTimeout("tcp", "localhost:3222", 5*time.Second) if err == nil { conn.Close()
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Apr 11 16:34:30 GMT 2022 - 23.4K bytes - Viewed (0) -
cmd/utils.go
// used while communicating with the cloud backends. func NewHTTPTransport() *http.Transport { return NewHTTPTransportWithTimeout(1 * time.Minute) } // Default values for dial timeout const defaultDialTimeout = 5 * time.Second // NewHTTPTransportWithTimeout allows setting a timeout. func NewHTTPTransportWithTimeout(timeout time.Duration) *http.Transport { return xhttp.ConnSettings{
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 31.3K bytes - Viewed (0)