- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 208 for HostPort (0.28 sec)
-
pkg/scheduler/framework/types_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 45.9K bytes - Viewed (0) -
pkg/kubelet/envvars/envvars.go
if sp.Protocol != "" { protocol = string(sp.Protocol) } hostPort := net.JoinHostPort(service.Spec.ClusterIP, strconv.Itoa(int(sp.Port))) if i == 0 { // Docker special-cases the first port. all = append(all, v1.EnvVar{ Name: prefix + "_PORT", Value: fmt.Sprintf("%s://%s", strings.ToLower(protocol), hostPort), }) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 09 11:14:08 UTC 2017 - 3.3K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/util/stats.go
// If the localHostAddr was not set, we use 'localhost' to void empty host in URL. if localHostAddr == "" { localHostAddr = "localhost" } hostPort := net.JoinHostPort(localHostAddr, strconv.Itoa(int(adminPort))) readinessURL := fmt.Sprintf("http://%s/stats?usedonly&filter=%s", hostPort, readyStatsRegex) stats, err := http.DoHTTPGetWithTimeout(readinessURL, readinessTimeout) if err != nil { return nil, false, err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 21 15:50:49 UTC 2022 - 4.8K bytes - Viewed (0) -
src/net/ip_test.go
// Opaque service name {"golang.org", "https%foo", "golang.org:https%foo"}, // Go 1 behavior } { if hostPort := JoinHostPort(tt.host, tt.port); hostPort != tt.hostPort { t.Errorf("JoinHostPort(%q, %q) = %q; want %q", tt.host, tt.port, hostPort, tt.hostPort) } } } var ipAddrFamilyTests = []struct { in IP af4 bool af6 bool }{ {IPv4bcast, true, false},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 07 01:17:29 UTC 2024 - 25.7K bytes - Viewed (0) -
pkg/scheduler/eventhandlers_test.go
st.MakePod().Name("p6").Obj(), st.MakePod().Name("p7").Node("invalid-node").Obj(), st.MakePod().Name("p8").HostPort(8080).Obj(), st.MakePod().Name("p9").HostPort(80).Obj(), }, want: []bool{true, false, false, true, false, true, false, true, false}, }, { name: "tainted node, pods with a single constraint", nodeFn: func() *v1.Node {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 10 14:38:54 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/api/pod/warnings.go
if port.HostIP == other.port.HostIP && port.HostPort == other.port.HostPort { // Exactly-equal is obvious. Validation should already filter for this except when these are unspecified. warnings = append(warnings, fmt.Sprintf("%s: duplicate port definition with %s", fldPath.Child("ports").Index(i), other.field)) } else if port.HostPort == 0 || other.port.HostPort == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 17:51:48 UTC 2024 - 16.6K bytes - Viewed (0) -
cluster/gce/manifests/etcd.manifest
"failureThreshold": 5 }, "ports": [ { "name": "serverport", "containerPort": {{ server_port }}, "hostPort": {{ server_port }} }, { "name": "clientport", "containerPort": {{ port }}, "hostPort": {{ port }} } ], "volumeMounts": [ { "name": "varetcd", "mountPath": "/var/etcd", "readOnly": false },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 03:36:35 UTC 2024 - 3.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/webhook/client.go
return nil, &ErrCallingWebhook{WebhookName: cc.Name, Reason: fmt.Errorf("Unparsable URL: %v", err)} } hostPort := u.Host if len(u.Port()) == 0 { // Default to port 443 if no port is specified hostPort = net.JoinHostPort(hostPort, "443") } restConfig, err := cm.authInfoResolver.ClientConfigFor(hostPort) if err != nil { return nil, err } cfg := rest.CopyConfig(restConfig)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 04 09:09:10 UTC 2024 - 7.3K bytes - Viewed (0) -
pkg/scheduler/internal/cache/cache_test.go
makeBasePod(t, nodeName, "test-resource-request-and-port-1", "100m", "500", "", []v1.ContainerPort{{HostIP: "127.0.0.1", HostPort: 80, Protocol: "TCP"}}), makeBasePod(t, nodeName, "test-resource-request-and-port-2", "200m", "1Ki", "", []v1.ContainerPort{{HostIP: "127.0.0.1", HostPort: 8080, Protocol: "TCP"}}),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 17 01:38:03 UTC 2023 - 63.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodeports/node_ports.go
usedPorts := make(framework.HostPortInfo) for _, container := range deletedPod.Spec.Containers { for _, podPort := range container.Ports { if podPort.HostPort > 0 { usedPorts.Add(podPort.HostIP, string(podPort.Protocol), podPort.HostPort) } } } // If the deleted pod doesn't use any host ports, it doesn't make the target pod schedulable. if len(usedPorts) == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 10:53:29 UTC 2024 - 7.5K bytes - Viewed (0)