Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for ContextDialer (0.25 sec)

  1. cmd/grid.go

    var globalGridStart = make(chan struct{})
    
    func initGlobalGrid(ctx context.Context, eps EndpointServerPools) error {
    	hosts, local := eps.GridHosts()
    	g, err := grid.NewManager(ctx, grid.ManagerOptions{
    		Dialer:       grid.ContextDialer(xhttp.DialContextWithLookupHost(globalDNSCache.LookupHost, xhttp.NewInternodeDialContext(rest.DefaultTimeout, globalTCPOptions))),
    		Local:        local,
    		Hosts:        hosts,
    		AddAuth:      newCachedAuthToken(),
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Mar 26 15:00:38 GMT 2024
    - 2K bytes
    - Viewed (0)
  2. internal/grid/connection.go

    	// 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.
    func (c ContextDialer) DialContext(ctx context.Context, network, address string) (net.Conn, error) {
    	return c(ctx, network, address)
    }
    
    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. internal/grid/manager.go

    	local string
    
    	// Validate incoming requests.
    	authRequest func(r *http.Request) error
    }
    
    // ManagerOptions are options for creating a new grid manager.
    type ManagerOptions struct {
    	Dialer       ContextDialer               // Outgoing dialer.
    	Local        string                      // Local host name.
    	Hosts        []string                    // All hosts, including local in the grid.
    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)
Back to top