Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 40 for Dial (0.2 sec)

  1. internal/deadlineconn/deadlineconn_test.go

    		}
    
    		// Send a response.
    		_, terr = io.WriteString(deadlineconn, "messages received\n")
    		if terr != nil {
    			t.Errorf("failed to write to client. %v", terr)
    			return
    		}
    	}()
    
    	c, err := net.Dial("tcp", serverAddr)
    	if err != nil {
    		t.Fatalf("unable to connect to server. %v", err)
    	}
    	defer c.Close()
    
    	_, err = io.WriteString(c, "message one\n")
    	if err != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Nov 05 18:09:21 GMT 2022
    - 3K bytes
    - Viewed (0)
  2. 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)
  3. common/scripts/metallb-native.yaml

                    minimum: 0
                    type: integer
                  peerAddress:
                    description: Address to dial when establishing the session.
                    type: string
                  peerPort:
                    description: Port to dial when establishing the session.
                    maximum: 16384
                    minimum: 0
                    type: integer
                  routerID:
    Others
    - Registered: Wed May 01 22:53:12 GMT 2024
    - Last Modified: Fri Feb 23 23:56:31 GMT 2024
    - 63.9K 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.15.txt

    pkg crypto/rsa, method (*PrivateKey) Equal(crypto.PrivateKey) bool
    pkg crypto/rsa, method (*PublicKey) Equal(crypto.PublicKey) bool
    pkg crypto/tls, method (*Dialer) Dial(string, string) (net.Conn, error)
    pkg crypto/tls, method (*Dialer) DialContext(context.Context, string, string) (net.Conn, error)
    pkg crypto/tls, method (ClientAuthType) String() string
    pkg crypto/tls, method (CurveID) String() string
    Plain Text
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Jul 17 02:15:01 GMT 2020
    - 7.6K bytes
    - Viewed (0)
  7. 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 Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.5K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. cmd/metrics-v2.go

    		Subsystem: trafficSubsystem,
    		Name:      "dial_errors",
    		Help:      "Total number of internode TCP dial timeouts and errors",
    		Type:      counterMetric,
    	}
    }
    
    func getInternodeTCPAvgDuration() MetricDescription {
    	return MetricDescription{
    		Namespace: interNodeMetricNamespace,
    		Subsystem: trafficSubsystem,
    		Name:      "dial_avg_time",
    		Help:      "Average time of internodes TCP dial calls",
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
Back to top