Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 95 for dial (0.07 seconds)

  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.
    //
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 2.6K bytes
    - Click Count (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 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Aug 21 04:25:07 GMT 2025
    - 10K bytes
    - Click Count (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.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 46.9K bytes
    - Click Count (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.                 |
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 43.4K bytes
    - Click Count (0)
  5. 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{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 33K bytes
    - Click Count (0)
  6. 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,
    	}
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 133.6K bytes
    - Click Count (0)
  7. 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()
    	}
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  8. src/cmd/asm/main.go

    			flags.D = append(flags.D, "GOEXPERIMENT_"+exp)
    		}
    	}
    
    	var ok, diag bool
    	var failedFile string
    	for _, f := range flag.Args() {
    		lexer := lex.NewLexer(f)
    		parser := asm.NewParser(ctxt, architecture, lexer)
    		ctxt.DiagFunc = func(format string, args ...any) {
    			diag = true
    			log.Printf(format, args...)
    		}
    		if *flags.SymABIs {
    			ok = parser.ParseSymABIs(buf)
    		} else {
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Thu Apr 02 17:07:18 GMT 2026
    - 3K bytes
    - Click Count (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
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Feb 13 13:48:53 GMT 2026
    - 4.9K bytes
    - Click Count (0)
  10. 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
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Sat Nov 01 08:52:09 GMT 2025
    - 1.2K bytes
    - Click Count (0)
Back to Top