Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for lookupHost (0.06 sec)

  1. internal/http/dial_dnscache.go

    	"context"
    	"net"
    	"time"
    )
    
    // LookupHost is a function to make custom lookupHost for optional cached DNS requests
    type LookupHost func(ctx context.Context, host string) (addrs []string, err error)
    
    // DialContextWithLookupHost is a helper function which returns `net.DialContext` function.
    // It randomly fetches an IP via custom LookupHost function and dials it by the given dial
    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. cmd/grid.go

    	hosts, local := eps.GridHosts()
    	lookupHost := globalDNSCache.LookupHost
    	g, err := grid.NewManager(ctx, grid.ManagerOptions{
    		// Pass Dialer for websocket grid, make sure we do not
    		// provide any DriveOPTimeout() function, as that is not
    		// useful over persistent connections.
    		Dialer: grid.ConnectWS(
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri May 16 14:27:42 UTC 2025
    - 3.7K bytes
    - Viewed (0)
  3. cmd/utils.go

    		etag += "-1"
    	}
    
    	return etag
    }
    
    // GetDefaultConnSettings returns default HTTP connection settings.
    func GetDefaultConnSettings() xhttp.ConnSettings {
    	return xhttp.ConnSettings{
    		LookupHost:  globalDNSCache.LookupHost,
    		DialTimeout: rest.DefaultTimeout,
    		RootCAs:     globalRootCAs,
    		TCPOptions:  globalTCPOptions,
    	}
    }
    
    // NewInternodeHTTPTransport returns a transport for internode MinIO
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 33K bytes
    - Viewed (0)
  4. internal/http/transports.go

    	ReadBufferSize = 64 << 10
    )
    
    // ConnSettings - contains connection settings.
    type ConnSettings struct {
    	DialContext DialContext // Custom dialContext, DialTimeout is ignored if this is already setup.
    	LookupHost  LookupHost  // Custom lookupHost, is nil on containerized deployments.
    	DialTimeout time.Duration
    
    	// TLS Settings
    	RootCAs          *x509.CertPool
    	CipherSuites     []uint16
    	CurvePreferences []tls.CurveID
    
    	// HTTP2
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 08 17:51:53 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  5. cmd/net.go

    			ipList.Add(ip.String())
    		}
    	}
    	return ipList
    }
    
    // getHostIP returns IP address of given host.
    func getHostIP(host string) (ipList set.StringSet, err error) {
    	addrs, err := globalDNSCache.LookupHost(GlobalContext, host)
    	if err != nil {
    		return ipList, err
    	}
    
    	ipList = set.NewStringSet()
    	for _, addr := range addrs {
    		ipList.Add(addr)
    	}
    
    	return ipList, err
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 9.6K bytes
    - Viewed (1)
  6. cmd/server-main.go

    		if host != "" {
    			if net.ParseIP(host) != nil {
    				ip = host
    			} else {
    				ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second)
    				defer cancel()
    
    				haddrs, err := globalDNSCache.LookupHost(ctx, host)
    				if err == nil {
    					ip = haddrs[0]
    				}
    			}
    		}
    		ifs, _ := net.Interfaces()
    		for _, interf := range ifs {
    			addrs, err := interf.Addrs()
    			if err == nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:18:36 UTC 2025
    - 35.9K bytes
    - Viewed (4)
  7. cmd/common-main.go

    		domainIPs := set.NewStringSet()
    		for _, endpoint := range minioEndpoints {
    			if net.ParseIP(endpoint) == nil {
    				// Checking if the IP is a DNS entry.
    				addrs, err := globalDNSCache.LookupHost(GlobalContext, endpoint)
    				if err != nil {
    					logger.FatalIf(err, "Unable to initialize MinIO server with [%s] invalid entry found in MINIO_PUBLIC_IPS", endpoint)
    				}
    				for _, addr := range addrs {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 32.5K bytes
    - Viewed (3)
  8. impl/maven-core/src/test/java/org/apache/maven/di/DiTest.java

                        },
                        new SisuDiBridgeModule(false));
            }
    
            @Test
            void testPlexus() throws Exception {
                List<ModelParser> parsers = container.lookupList(ModelParser.class);
                assertNotNull(parsers);
                assertEquals(1, parsers.size());
                Map<String, ModelParser> parsersMap = container.lookupMap(ModelParser.class);
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Mon Feb 10 23:18:32 UTC 2025
    - 12.4K bytes
    - Viewed (0)
  9. impl/maven-core/src/main/java/org/apache/maven/internal/impl/DefaultTypeRegistry.java

        }
    
        @Override
        @Nonnull
        public Type require(String id) {
            requireNonNull(id, "id cannot be null");
            return usedTypes.computeIfAbsent(id, i -> {
                Type type = lookup.lookupList(TypeProvider.class).stream()
                        .flatMap(p -> p.provides().stream())
                        .filter(t -> Objects.equals(id, t.id()))
                        .findFirst()
                        .orElse(null);
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed May 14 04:47:58 UTC 2025
    - 4K bytes
    - Viewed (0)
  10. impl/maven-core/src/main/java/org/apache/maven/execution/MavenSession.java

            return container.lookup(role, roleHint);
        }
    
        @Deprecated
        public List<Object> lookupList(String role) throws ComponentLookupException {
            return container.lookupList(role);
        }
    
        @Deprecated
        public Map<String, Object> lookupMap(String role) throws ComponentLookupException {
            return container.lookupMap(role);
        }
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Jan 24 17:29:44 UTC 2025
    - 16.7K bytes
    - Viewed (0)
Back to top