Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for externalapi (0.5 sec)

  1. pkg/proxy/winkernel/proxier.go

    		svcInfo.nodePorthnsID = ""
    	}
    
    	for _, externalIP := range svcInfo.externalIPs {
    		mapStaleLoadbalancer[externalIP.hnsID] = true
    		if err := hns.deleteLoadBalancer(externalIP.hnsID); err != nil {
    			klog.V(1).ErrorS(err, "Error deleting Hns ExternalIP policy resource.", "hnsID", externalIP.hnsID, "IP", externalIP.ip)
    		} else {
    			// On successful delete, remove hnsId
    			externalIP.hnsID = ""
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 59K bytes
    - Viewed (0)
  2. pkg/proxy/nftables/proxier.go

    				Comment: &svcPortNameString,
    			})
    		}
    
    		// Capture externalIPs.
    		for _, externalIP := range svcInfo.ExternalIPs() {
    			if hasEndpoints {
    				// Send traffic bound for external IPs to the "external
    				// destinations" chain.
    				tx.Add(&knftables.Element{
    					Map: serviceIPsMap,
    					Key: []string{
    						externalIP.String(),
    						protocol,
    						strconv.Itoa(svcInfo.Port()),
    					},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  3. pkg/proxy/iptables/proxier.go

    				"-d", svcInfo.ClusterIP().String(),
    				"--dport", strconv.Itoa(svcInfo.Port()),
    				"-j", internalTrafficFilterTarget,
    			)
    		}
    
    		// Capture externalIPs.
    		for _, externalIP := range svcInfo.ExternalIPs() {
    			if hasEndpoints {
    				// Send traffic bound for external IPs to the "external
    				// destinations" chain.
    				natRules.Write(
    					"-A", string(kubeServicesChain),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  4. pkg/proxy/ipvs/proxier.go

    		} else {
    			proxier.logger.Error(err, "Failed to sync service", "servicePortName", svcPortName, "virtualServer", serv)
    		}
    
    		// Capture externalIPs.
    		for _, externalIP := range svcInfo.ExternalIPs() {
    			// ipset call
    			entry := &utilipset.Entry{
    				IP:       externalIP.String(),
    				Port:     svcInfo.Port(),
    				Protocol: protocol,
    				SetType:  utilipset.HashIPPort,
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
  5. pkg/kubelet/kuberuntime/kuberuntime_manager.go

    	cpuCFSQuotaPeriod metav1.Duration
    
    	// wrapped image puller.
    	imagePuller images.ImageManager
    
    	// gRPC service clients
    	runtimeService internalapi.RuntimeService
    	imageService   internalapi.ImageManagerService
    
    	// The version cache of runtime daemon.
    	versionCache *cache.ObjectCache
    
    	// The directory path for seccomp profiles.
    	seccompProfileRoot string
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 22 02:01:31 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  6. pkg/kubelet/nodestatus/setters_test.go

    				{Type: v1.NodeHostName, Address: testKubeletHostname},
    			},
    			shouldError: false,
    		},
    		{
    			// Accommodating #45201 and #49202
    			name:   "InternalIP and ExternalIP are the same",
    			nodeIP: netutils.ParseIPSloppy("55.55.55.55"),
    			nodeAddresses: []v1.NodeAddress{
    				{Type: v1.NodeInternalIP, Address: "44.44.44.44"},
    				{Type: v1.NodeExternalIP, Address: "44.44.44.44"},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 21:47:24 UTC 2024
    - 76.1K bytes
    - Viewed (0)
  7. pkg/apis/core/v1/defaults_test.go

    		t.Errorf("Expected ExternalTrafficPolicy to be %v, got %v", v1.ServiceExternalTrafficPolicyCluster, out.Spec.ExternalTrafficPolicy)
    	}
    
    	in = &v1.Service{Spec: v1.ServiceSpec{Type: v1.ServiceTypeClusterIP, ExternalIPs: []string{"1.2.3.4"}}}
    	obj = roundTrip(t, runtime.Object(in))
    	out = obj.(*v1.Service)
    	if out.Spec.ExternalTrafficPolicy != v1.ServiceExternalTrafficPolicyCluster {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 84.4K bytes
    - Viewed (0)
Back to top