- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 55 for ep (0.02 sec)
-
releasenotes/notes/fix-se-stale-ep.yaml
Ying Zhu <******@****.***> 1634065099 -0700
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 12 18:58:19 UTC 2021 - 293 bytes - Viewed (0) -
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/controller/endpointslicemirroring/utils_test.go
}, }, { name: "create slice from endpoints with labels and annotations", tweakEndpoint: func(ep *v1.Endpoints) { labels := map[string]string{"foo": "bar"} ep.Labels = labels annotations := map[string]string{"foo2": "bar2"} ep.Annotations = annotations }, expectedSlice: discovery.EndpointSlice{ ObjectMeta: metav1.ObjectMeta{ Labels: map[string]string{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 23 15:40:23 UTC 2022 - 7.5K 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/model/proxy_view.go
getValue: func(ep *IstioEndpoint) string { return ep.Network.String() }, } } type proxyViewImpl struct { visible sets.String getValue func(ep *IstioEndpoint) string } func (v *proxyViewImpl) IsVisible(ep *IstioEndpoint) bool { return v.visible.Contains(v.getValue(ep)) } func (v *proxyViewImpl) String() string {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 15 16:11:16 UTC 2023 - 1.8K 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) -
pkg/proxy/winkernel/testing/hcnutils_mock.go
for _, ep := range endpointMap { hcnEPList = append(hcnEPList, *ep) } return hcnEPList, nil } func (hcnObj HcnMock) ListEndpointsOfNetwork(networkId string) ([]hcn.HostComputeEndpoint, error) { var hcnEPList []hcn.HostComputeEndpoint for _, ep := range endpointMap { if ep.HostComputeNetwork == networkId { hcnEPList = append(hcnEPList, *ep) } } return hcnEPList, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 18 06:29:01 UTC 2023 - 6.2K bytes - Viewed (0)