- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 334 for endpoints1 (0.42 sec)
-
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) -
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) -
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) -
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) -
pkg/workloadapi/workload.proto
// that match less (or, eventually, none) preferences. // For instance, with `[NETWORK, REGION, ZONE]`, we will send to: // 1. Endpoints matching `[NETWORK, REGION, ZONE]` // 2. Endpoints matching `[NETWORK, REGION]` // 3. Endpoints matching `[NETWORK]` // 4. Any endpoints FAILOVER = 2; }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 18:02:35 UTC 2024 - 12.9K bytes - Viewed (0) -
pkg/kubelet/stats/cri_stats_provider_windows.go
continue } // only add the interface for each container if not already in the list for _, cId := range endpoint.SharedContainers { networkStat, found := networkStats[cId] if found && networkStat.Name != endpoint.Name { iStat := hcsStatToInterfaceStat(endpointStats, endpoint.Name)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Feb 18 07:03:11 UTC 2024 - 10.4K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/endpoint_builder.go
healthStatus = model.Draining } ep := &endpoint.LbEndpoint{ HealthStatus: corev3.HealthStatus(healthStatus), LoadBalancingWeight: &wrapperspb.UInt32Value{ Value: e.GetLoadBalancingWeight(), }, HostIdentifier: &endpoint.LbEndpoint_Endpoint{ Endpoint: &endpoint.Endpoint{ Address: addr, }, }, Metadata: &corev3.Metadata{}, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 02:18:19 UTC 2024 - 26.1K bytes - Viewed (0) -
pkg/proxy/healthcheck/healthcheck_test.go
} if hcs.services[nsn1].endpoints != 0 { t.Errorf("expected 0 endpoints, got %d", hcs.services[nsn1].endpoints) } if hcs.services[nsn2].endpoints != 0 { t.Errorf("expected 0 endpoints, got %d", hcs.services[nsn2].endpoints) } if hcs.services[nsn3].endpoints != 0 { t.Errorf("expected 0 endpoints, got %d", hcs.services[nsn3].endpoints) } if len(listener.openPorts) != 3 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 21.4K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go
// onEndpointsAdd queues a sync for the relevant Endpoints resource. func (c *Controller) onEndpointsAdd(logger klog.Logger, obj interface{}) { endpoints := obj.(*v1.Endpoints) if endpoints == nil { utilruntime.HandleError(fmt.Errorf("onEndpointsAdd() expected type v1.Endpoints, got %T", obj)) return } if !c.shouldMirror(endpoints) { logger.V(5).Info("Skipping mirroring", "endpoints", klog.KObj(endpoints)) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 23:18:31 UTC 2024 - 20.1K bytes - Viewed (0)