- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 177 for localisty (0.15 sec)
-
pkg/test/loadbalancersim/mesh/node.go
n.q.Schedule(wrappedOnDone, deadline) }, onDone) } func (n *Node) Locality() locality.Instance { return n.locality } func (n *Node) ShutDown() { n.q.ShutDown() } type Nodes []*Node func (nodes Nodes) Select(match locality.Match) Nodes { var out Nodes for _, n := range nodes { if match(n.locality) { out = append(out, n) } } return out }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 03 18:19:25 UTC 2022 - 3.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpoint_builder.go
return out } func (c *Controller) NewEndpointBuilderFromMetadata(proxy *model.Proxy) *EndpointBuilder { locality := util.LocalityToString(proxy.Locality) out := &EndpointBuilder{ controller: c, metaNetwork: proxy.Metadata.Network, serviceAccount: proxy.Metadata.ServiceAccount, locality: model.Locality{ Label: locality,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 4.8K bytes - Viewed (0) -
tests/testdata/config/static-weighted-se.yaml
ports: - number: 80 name: http protocol: HTTP resolution: STATIC endpoints: - address: 3.3.3.3 locality: a - address: 2.2.2.2 locality: a weight: 8 - address: 1.1.1.1 locality: b
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 18 01:09:21 UTC 2019 - 394 bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/endpoint.go
if includeConfigType { addr = fmt.Sprintf("endpoint/%s", addr) } fmt.Fprintf(w, "%v\t%v\t%v\t%v\n", addr, ep.GetHealthStatus().String(), util.LocalityToString(llb.Locality), eds.ClusterName, ) } } } return w.Flush() } func (c *ConfigWriter) retrieveSortedEndpointsSlice(filter EndpointFilter) ([]*endpoint.ClusterLoadAssignment, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 5.6K bytes - Viewed (0) -
pilot/pkg/networking/util/util_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 01:17:58 UTC 2024 - 40K bytes - Viewed (0) -
pkg/bootstrap/platform/aws_test.go
t.Run(v.name, func(tt *testing.T) { server, url := setupHTTPServer(v.handlers) defer server.Close() awsMetadataIPv4URL = url.String() locality := NewAWS(false).Locality() if !reflect.DeepEqual(locality, v.want) { t.Errorf("unexpected locality. want :%v, got :%v", v.want, locality) } }) } } func TestIsAWS(t *testing.T) { cases := []struct { name string handlers map[string]handlerFunc
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 18 13:10:06 UTC 2022 - 3.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpoint_builder_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 7.8K bytes - Viewed (0) -
pkg/test/loadbalancersim/lb_test.go
} wg.Wait() c := s.mesh.Clients()[0] clientLocality := c.Locality() clientLatency := clientLatencies[0] nodesSameZone := s.mesh.Nodes().Select(locality.MatchZone(clientLocality)) nodesSameRegion := s.mesh.Nodes().Select(locality.MatchOtherZoneInSameRegion(clientLocality)) nodesOtherRegion := s.mesh.Nodes().Select(locality.Not(locality.MatchRegion(clientLocality))) // Store in the output.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 19 23:29:30 UTC 2022 - 11K bytes - Viewed (0) -
pkg/test/framework/components/echo/kube/templates/deployment.yaml
{{- if ne $.Locality "" }} istio-locality: {{ $.Locality }} {{- end }} template: metadata: labels: app: {{ $.Service }} version: {{ $subset.Version }} test.istio.io/class: {{ $.WorkloadClass }} {{- if $.Compatibility }} istio.io/rev: {{ $revision }} {{- end }} {{- if ne $.Locality "" }} istio-locality: {{ $.Locality }} {{- end }}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 02 21:29:40 UTC 2024 - 6.1K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_test.go
for _, localityLbEndpoint := range c.LoadAssignment.Endpoints { locality := localityLbEndpoint.Locality if locality.Region == "region1" && locality.Zone == "zone1" && locality.SubZone == "subzone1" { g.Expect(localityLbEndpoint.Priority).To(Equal(uint32(0))) } else if locality.Region == "region1" && locality.Zone == "zone1" && locality.SubZone == "subzone2" { g.Expect(localityLbEndpoint.Priority).To(Equal(uint32(1)))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 108.8K bytes - Viewed (0)