Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for Dial (0.15 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
Back to top