- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 133 for ep (0.02 sec)
-
pkg/proxy/topology.go
for _, ep := range clusterEndpoints { endpointsMap[ep.String()] = ep } for _, ep := range localEndpoints { endpointsMap[ep.String()] = ep } allReachableEndpoints = make([]Endpoint, 0, len(endpointsMap)) for _, ep := range endpointsMap { allReachableEndpoints = append(allReachableEndpoints, ep) } return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 06:46:03 UTC 2024 - 7.4K bytes - Viewed (0) -
src/os/executable_darwin.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 19:57:43 UTC 2024 - 675 bytes - Viewed (0) -
pilot/test/xdstest/endpoints.go
return addrI < addrJ }) for i, ep := range got { if len(ep.LbEndpoints) != len(want[i].LbEps) { return fmt.Errorf("unexpected number of LB endpoints within endpoint %d: %v, want %v", i, getLbEndpointAddrs(ep), want[i].GetAddrs()) } if ep.LoadBalancingWeight.GetValue() != want[i].Weight { return fmt.Errorf("unexpected weight for endpoint %d: got %v, want %v", i, ep.LoadBalancingWeight.GetValue(), want[i].Weight) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 01:17:58 UTC 2024 - 2.8K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/endpoint.go
return false } status := retrieveEndpointStatus(ep) if e.Status != "" && !strings.EqualFold(core.HealthStatus_name[int32(status)], e.Status) { return false } return true } func retrieveEndpointStatus(ep *endpoint.LbEndpoint) core.HealthStatus { return ep.GetHealthStatus() } func retrieveEndpointPort(ep *endpoint.LbEndpoint) uint32 { return ep.GetEndpoint().GetAddress().GetSocketAddress().GetPortValue() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 5.6K bytes - Viewed (0) -
pkg/proxy/winkernel/hns.go
// TODO: Store by IP only and remove any lookups by endpoint ID. endpointInfos[ep.Id] = &endpointInfo{ ip: ep.IpConfigurations[0].IpAddress, isLocal: uint32(ep.Flags&hcn.EndpointFlagsRemoteEndpoint) == 0, macAddress: ep.MacAddress, hnsID: ep.Id, hns: hns, // only ready and not terminating endpoints were added to HNS ready: true,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 09 21:21:12 UTC 2023 - 15K bytes - Viewed (0) -
cmd/endpoint.go
*url.URL IsLocal bool PoolIdx, SetIdx, DiskIdx int } // Equal returns true if endpoint == ep func (endpoint Endpoint) Equal(ep Endpoint) bool { if endpoint.IsLocal == ep.IsLocal && endpoint.PoolIdx == ep.PoolIdx && endpoint.SetIdx == ep.SetIdx && endpoint.DiskIdx == ep.DiskIdx { if endpoint.Path == ep.Path && endpoint.Host == ep.Host { return true } } return false } func (endpoint Endpoint) String() string {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 34.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceexportcache_test.go
ep := ec.getEndpoint(endpoints) if ep == nil { return fmt.Errorf("expected an endpoint, found none") } return ec.checkEndpoint(exported, ep) } func (ec *serviceExportCacheImpl) checkEndpoint(exported bool, ep *model.IstioEndpoint) error { // Should always be discoverable from the same cluster. if err := ec.checkDiscoverableFromSameCluster(ep); err != nil { return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 18:50:38 UTC 2023 - 9.1K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/endpoint_builder.go
// 2. ep.Address can be uds when EndpointPort = 0 if ep.Address != "" && ep.EndpointPort != 0 && !netutil.IsValidIPAddress(ep.Address) { return false } // filter out endpoints that don't match the subset if !b.subsetLabels.SubsetOf(ep.Labels) { return false } return true }) localityLbEndpoints := b.generate(svcEps)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 02:18:19 UTC 2024 - 26.1K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/ep_filters.go
} return gws } func (b *EndpointBuilder) scaleEndpointLBWeight(ep *endpoint.LbEndpoint, scaleFactor uint32) uint32 { if ep.GetLoadBalancingWeight() == nil || ep.GetLoadBalancingWeight().Value == 0 { return scaleFactor } weight := uint32(math.MaxUint32) if ep.GetLoadBalancingWeight().Value < math.MaxUint32/scaleFactor { weight = ep.GetLoadBalancingWeight().Value * scaleFactor } return weight }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 01:17:58 UTC 2024 - 9.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpointslice.go
} return err.ErrorOrNil() } func (esc *endpointSliceController) onEvent(_, ep *v1.EndpointSlice, event model.Event) error { esc.onEventInternal(nil, ep, event) return nil } func (esc *endpointSliceController) onEventInternal(_, ep *v1.EndpointSlice, event model.Event) { esLabels := ep.GetLabels() if !endpointSliceSelector.Matches(klabels.Set(esLabels)) { return }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 16.9K bytes - Viewed (0)