- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 153 for ep (0.04 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/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) -
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/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/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)