- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 40 for parseShort (0.46 sec)
-
internal/logger/config.go
if len(kafkaBrokers) == 0 { return cfg, config.Errorf("kafka 'brokers' cannot be empty") } for _, s := range strings.Split(kafkaBrokers, config.ValueSeparator) { var host *xnet.Host host, err = xnet.ParseHost(s) if err != nil { break } brokers = append(brokers, *host) } if err != nil { return cfg, err }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15.8K bytes - Viewed (0) -
cmd/endpoint.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 34.1K bytes - Viewed (0) -
cmd/handler-utils.go
func getResource(path string, host string, domains []string) (string, error) { if len(domains) == 0 { return path, nil } // If virtual-host-style is enabled construct the "resource" properly. xhost, err := xnet.ParseHost(host) if err != nil { return "", err } for _, domain := range domains { if xhost.Name == minioReservedBucket+"."+domain { continue } if !strings.HasSuffix(xhost.Name, "."+domain) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 15.5K bytes - Viewed (0) -
pilot/pkg/model/context.go
if len(parts) > 1 { // k8s will have namespace.<domain> return parts[0] } return "" } const ( serviceNodeSeparator = "~" ) // ParsePort extracts port number from a valid proxy address func ParsePort(addr string) int { _, sPort, err := net.SplitHostPort(addr) if sPort == "" { return 0 } if err != nil { log.Warn(err) } port, pErr := strconv.Atoi(sPort)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 33.6K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/HttpUrl.kt
if (portColonOffset + 1 < componentDelimiterOffset) { host = input.percentDecode(pos = pos, limit = portColonOffset).toCanonicalHost() port = parsePort(input, portColonOffset + 1, componentDelimiterOffset) require(port != -1) { "Invalid URL port: \"${input.substring( portColonOffset + 1,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Jan 09 12:33:05 UTC 2024 - 63.5K bytes - Viewed (0) -
cmd/kubeadm/app/apis/kubeadm/validation/validation.go
} return allErrs } // ValidatePort validates port numbers func ValidatePort(port int32, fldPath *field.Path) field.ErrorList { allErrs := field.ErrorList{} if _, err := kubeadmutil.ParsePort(strconv.Itoa(int(port))); err != nil { allErrs = append(allErrs, field.Invalid(fldPath, port, "port number is not valid")) } return allErrs } // ValidateHostPort validates host[:port] endpoints
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 16:01:49 UTC 2024 - 33.4K bytes - Viewed (0) -
src/net/lookup.go
// // The network must be one of "tcp", "tcp4", "tcp6", "udp", "udp4", "udp6" or "ip". func (r *Resolver) LookupPort(ctx context.Context, network, service string) (port int, err error) { port, needsLookup := parsePort(service) if needsLookup { switch network { case "tcp", "tcp4", "tcp6", "udp", "udp4", "udp6", "ip": case "": // a hint wildcard for Go 1.0 undocumented behavior network = "ip" default:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:23:45 UTC 2024 - 28.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/config.go
addr := s.Listener.Addr().String() host, portStr, err := net.SplitHostPort(addr) if err != nil { return "", 0, fmt.Errorf("failed to get port from listener address %q: %v", addr, err) } port, err := utilsnet.ParsePort(portStr, true) if err != nil { return "", 0, fmt.Errorf("invalid non-numeric port %q", portStr) } return host, port, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 47.7K bytes - Viewed (0) -
cmd/notification.go
ctx := logger.SetReqInfo(ctx, reqInfo) peersLogOnceIf(ctx, err, client.host.String()) } } } // Local host thisAddr, err := xnet.ParseHost(globalLocalNodeName) if err != nil { bugLogIf(ctx, err) return profilingDataFound } data, err := getProfileData() if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 44.9K bytes - Viewed (0) -
cmd/admin-handlers.go
writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrServerNotInitialized), r.URL) return } vars := mux.Vars(r) profiles := strings.Split(vars["profilerType"], ",") thisAddr, err := xnet.ParseHost(globalLocalNodeName) if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } globalProfilerMu.Lock() defer globalProfilerMu.Unlock()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0)