Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 208 for HostPort (0.28 sec)

  1. pkg/scheduler/framework/types_test.go

    				v1.ResourceCPU:    "100m",
    				v1.ResourceMemory: "500",
    			}).ContainerPort([]v1.ContainerPort{{
    				HostIP:   "127.0.0.1",
    				HostPort: 80,
    				Protocol: "TCP",
    			}}).Obj()}).
    			Obj(),
    
    		st.MakePod().UID("test-2").Namespace("node_info_cache_test").Name("test-2").Node(nodeName).
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 45.9K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top