- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for lookupHost (0.31 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
impl/maven-core/src/main/java/org/apache/maven/internal/impl/DefaultLookup.java
return Optional.empty(); } throw new LookupException(e); } } @Override public <T> List<T> lookupList(Class<T> type) { try { return container.lookupList(type); } catch (ComponentLookupException e) { throw new LookupException(e); } } @Override
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 3.1K bytes - Viewed (0) -
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) -
impl/maven-core/src/test/java/org/apache/maven/SimpleLookup.java
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 2K bytes - Viewed (0)