- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for lookupHost (0.06 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/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/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) -
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)