Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 55 for dial (0.02 sec)

  1. 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.
    //
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 2.6K bytes
    - Viewed (0)
  2. 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 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Aug 21 04:25:07 UTC 2025
    - 10K bytes
    - Viewed (0)
  3. internal/grid/connection.go

    	// Incoming streams
    	inStream *xsync.MapOf[uint64, *muxServer]
    
    	// outQueue is the output queue
    	outQueue chan []byte
    
    	// Client or serverside.
    	side ws.State
    
    	// Dialer for outgoing connections.
    	dial   ConnDialer
    	authFn AuthFn
    
    	handleMsgWg sync.WaitGroup
    
    	// connChange will be signaled whenever State has been updated, or at regular intervals.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 46.9K bytes
    - Viewed (0)
  4. 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()
    	}
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  5. 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.                 |
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 43.4K bytes
    - Viewed (0)
  6. 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{
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 33K bytes
    - Viewed (0)
  7. cmd/metrics-v2.go

    		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",
    		Type:      gaugeMetric,
    	}
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 133.6K bytes
    - Viewed (0)
  8. LICENSES/vendor/github.com/Masterminds/semver/v3/LICENSE

    Copyright (C) 2014-2019, Matt Butcher and Matt Farina
    
    Permission is hereby granted, free of charge, to any person obtaining a copy
    of this software and associated documentation files (the "Software"), to deal
    in the Software without restriction, including without limitation the rights
    to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
    copies of the Software, and to permit persons to whom the Software is
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Sat Nov 01 08:52:09 UTC 2025
    - 1.2K bytes
    - Viewed (0)
  9. docs/pt/docs/tutorial/security/index.md

    ### OAuth 1 { #oauth-1 }
    
    Havia um OAuth 1, que é bem diferente do OAuth2, e mais complexo, isso incluía diretamente as especificações de como criptografar a comunicação.
    
    Não é muito popular ou usado nos dias atuais.
    
    OAuth2 não especifica como criptografar a comunicação, ele espera que você tenha sua aplicação em um servidor HTTPS.
    
    /// tip | Dica
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 10:17:03 UTC 2025
    - 4.9K bytes
    - Viewed (0)
  10. docs/es/docs/tutorial/security/index.md

    ### OAuth 1 { #oauth-1 }
    
    Hubo un OAuth 1, que es muy diferente de OAuth2, y más complejo, ya que incluía especificaciones directas sobre cómo encriptar la comunicación.
    
    No es muy popular o usado hoy en día.
    
    OAuth2 no especifica cómo encriptar la comunicación, espera que tengas tu aplicación servida con HTTPS.
    
    /// tip | Consejo
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 10:15:01 UTC 2025
    - 4.8K bytes
    - Viewed (0)
Back to top