Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 1,163 for endpoints2 (0.32 sec)

  1. pkg/proxy/iptables/number_generated_rules_test.go

    				}
    				if len(eps[i].Endpoints) != test.epPerService {
    					t.Fatalf("expected %d endpoints per slice , received %d", test.epPerService, len(eps[i].Endpoints))
    				}
    				for j := 0; j < test.epPerService; j++ {
    					nodeName := fmt.Sprintf("node-%d", j)
    					if *eps[i].Endpoints[j].NodeName != nodeName {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/kube/controller/network.go

    			return ""
    		}
    		if len(entries) > 1 {
    			log.Warnf("Found multiple networks CIDRs matching the endpoint IP: %s. Using the first match.", endpointIP)
    		}
    		if len(entries) > 0 {
    			return (entries[0].(namedRangerEntry)).name
    		}
    	}
    	return ""
    }
    
    // namedRangerEntry for holding network's CIDR and name
    type namedRangerEntry struct {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 22:23:22 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  3. pkg/proxy/winkernel/hns_test.go

    		t.Errorf("%v does not match %v", endpoint.hnsID, Endpoint.Id)
    	}
    	if endpoint.ip != Endpoint.IpConfigurations[0].IpAddress {
    		t.Errorf("%v does not match %v", endpoint.ip, Endpoint.IpConfigurations[0].IpAddress)
    	}
    	if endpoint.macAddress != Endpoint.MacAddress {
    		t.Errorf("%v does not match %v", endpoint.macAddress, Endpoint.MacAddress)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:24:16 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  4. releasenotes/notes/fix-proxyconfig-endpoints-json.yaml

    Keith Mattix II <******@****.***> 1694141094 -0500
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Sep 08 02:44:54 UTC 2023
    - 205 bytes
    - Viewed (0)
  5. pkg/proxy/nftables/proxier.go

    	// set of active ClusterIPs.
    	clusterIPsSet = "cluster-ips"
    
    	// handling for services with no endpoints
    	serviceEndpointsCheckChain  = "service-endpoints-check"
    	nodePortEndpointsCheckChain = "nodeport-endpoints-check"
    	noEndpointServicesMap       = "no-endpoint-services"
    	noEndpointNodePortsMap      = "no-endpoint-nodeports"
    	rejectChain                 = "reject-chain"
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  6. pilot/pkg/xds/eds_sh_test.go

    			// endpoints weighted accordingly with the IP of the ingress gateway.
    			network:   "network3",
    			sidecarID: sidecarID("10.3.0.1", "app3"),
    			want: expectedResults{
    				weights: map[string]uint32{
    					// 3 local endpoints.
    					"10.3.0.1": 2,
    					"10.3.0.2": 2,
    					"10.3.0.3": 2,
    
    					// 1 endpoint on network 1, accessed via gateway.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jan 12 18:20:36 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  7. pkg/controller/endpointslicemirroring/reconciler_helpers.go

    		endpointsByKey:      map[addrTypePortMapKey]endpointsliceutil.EndpointSet{},
    		numDesiredEndpoints: 0,
    	}
    }
    
    // desiredCalc helps calculate desired endpoints and ports.
    type desiredCalc struct {
    	portsByKey          map[addrTypePortMapKey][]discovery.EndpointPort
    	endpointsByKey      map[addrTypePortMapKey]endpointsliceutil.EndpointSet
    	numDesiredEndpoints int
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 11 18:08:12 UTC 2023
    - 4.7K bytes
    - Viewed (0)
  8. pkg/kubelet/stats/cri_stats_provider_windows_test.go

    		for _, stat := range c.hcsStats {
    			e, found := uniqueEndpoints[stat.EndpointId]
    			if found {
    				// add the container
    				e.SharedContainers = append(e.SharedContainers, c.container.ID)
    				continue
    			}
    
    			uniqueEndpoints[stat.EndpointId] = &hcsshim.HNSEndpoint{
    				Name:             stat.EndpointId,
    				Id:               stat.EndpointId,
    				SharedContainers: []string{c.container.ID},
    			}
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Feb 17 00:02:10 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  9. pilot/pkg/networking/util/util.go

    func cloneLocalityLbEndpoints(endpoints []*endpoint.LocalityLbEndpoints) []*endpoint.LocalityLbEndpoints {
    	out := make([]*endpoint.LocalityLbEndpoints, 0, len(endpoints))
    	for _, ep := range endpoints {
    		clone := CloneLocalityLbEndpoint(ep)
    		out = append(out, clone)
    	}
    	return out
    }
    
    // return a shallow copy of LocalityLbEndpoints
    func CloneLocalityLbEndpoint(ep *endpoint.LocalityLbEndpoints) *endpoint.LocalityLbEndpoints {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 28.5K bytes
    - Viewed (0)
  10. pkg/controller/endpointslicemirroring/reconciler_test.go

    	// canonicalize endpoints to match the expected endpoints, otherwise the test
    	// that creates more endpoints than allowed fail becaused the list of final
    	// endpoints doesn't match.
    	for _, epSubset := range endpointsv1.RepackSubsets(endpoints.Subsets) {
    		if len(epSubset.Addresses) == 0 && len(epSubset.NotReadyAddresses) == 0 {
    			continue
    		}
    
    		var matchingEndpointsV4, matchingEndpointsV6 []discovery.Endpoint
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 42.7K bytes
    - Viewed (0)
Back to top