- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 853 for endpoints1 (0.25 sec)
-
pkg/controller/endpoint/endpoints_controller.go
return !ok } // truncateEndpoints by best effort will distribute the endpoints over the subsets based on the proportion // of endpoints per subset and will prioritize Ready Endpoints over NotReady Endpoints. func truncateEndpoints(endpoints *v1.Endpoints) bool { totalReady := 0 totalNotReady := 0 for _, subset := range endpoints.Subsets { totalReady += len(subset.Addresses)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 26.3K bytes - Viewed (0) -
pkg/proxy/winkernel/proxier_test.go
eps.AddressType = discovery.AddressTypeIPv4 eps.Endpoints = []discovery.Endpoint{{ Addresses: []string{epIpAddressRemote}, NodeName: ptr.To("testhost2"), // This will make this endpoint as a remote endpoint }} eps.Ports = []discovery.EndpointPort{{ Name: ptr.To(svcPortName.Port), Port: ptr.To(int32(svcPort)),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 28 14:30:51 UTC 2024 - 30.2K bytes - Viewed (0) -
cmd/bootstrap-peer-server.go
var clnts []*bootstrapRESTClient for _, ep := range endpointServerPools { for _, endpoint := range ep.Endpoints { if endpoint.IsLocal { continue } if seenClient.Contains(endpoint.Host) { continue } seenClient.Add(endpoint.Host) clnts = append(clnts, &bootstrapRESTClient{gm.Connection(endpoint.GridHost())}) } } return clnts
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 7.5K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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)