- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 1,407 for distances (0.16 sec)
-
pilot/pkg/serviceregistry/util/workloadinstances/util.go
if !slices.Contains(proxy.IPAddresses, proxyIP) { return nil } instances := index.GetByIP(proxyIP) // list is ordered by namespace/name if len(instances) == 0 { return nil } if len(instances) == 1 { // dominant use case // NOTE: for the sake of backwards compatibility, we don't enforce // instance.Namespace == proxy.ConfigNamespace return instances[0] } // try to find workload instance with the same name as proxy
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 17:36:41 UTC 2023 - 2.8K bytes - Viewed (0) -
pkg/test/framework/components/echo/deployment/builder.go
} func assignRefs(refs []*echo.Instance, instances echo.Instances) error { if len(refs) != len(instances) { return fmt.Errorf("cannot set %d references, only %d instances were built", len(refs), len(instances)) } for i, ref := range refs { if ref != nil { *ref = instances[i] } } return nil } func (b *builder) BuildOrFail(t test.Failer) echo.Instances { t.Helper() out, err := b.Build()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 12K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/store_test.go
store.addInstances(cpKey, instances) // 1. test getByIP gotInstances := store.getByIP("1.1.1.1") if !reflect.DeepEqual(instances, gotInstances) { t.Errorf("got unexpected instances : %v", gotInstances) } // 2. test getAll gotInstances = store.getAll() if !reflect.DeepEqual(instances, gotInstances) { t.Errorf("got unexpected instances : %v", gotInstances) } // 3. test getByKey
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 8.1K bytes - Viewed (0) -
pkg/test/framework/components/echo/echotest/run.go
doTest(ctx, c, dstInstances) }) } }) } func (t *T) isMultipleNamespaces() bool { namespaces := map[string]struct{}{} for _, instances := range []echo.Instances{t.sources, t.destinations} { for _, i := range instances { namespaces[i.Config().Namespace.Name()] = struct{}{} if len(namespaces) > 1 { return true } } } return false }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Sep 27 22:08:42 UTC 2023 - 13K bytes - Viewed (0) -
pkg/test/framework/components/echo/match/matchers.go
return !m(i) } } // ServiceName matches instances with the given namespace and service name. func ServiceName(n echo.NamespacedName) Matcher { return func(i echo.Instance) bool { return n == i.NamespacedName() } } // AnyServiceName matches instances if they have the same Service and Namespace as any of the provided instances. func AnyServiceName(expected echo.NamespacedNames) Matcher {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 02 21:29:40 UTC 2024 - 5.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/util/workloadinstances/selector.go
func FindAllInIndex(index Index, predicate func(*model.WorkloadInstance) bool) []*model.WorkloadInstance { var instances []*model.WorkloadInstance index.ForEach(func(instance *model.WorkloadInstance) { if predicate(instance) { instances = append(instances, instance) } }) return instances
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 07 04:26:56 UTC 2023 - 1.4K bytes - Viewed (0) -
pkg/test/framework/components/echo/common/deployment/namespace.go
D echo.Instances // IPv6 only echo app to be used by tests if running in dual-stack mode E echo.Instances // Standard echo app with TPROXY interception mode to be used by tests Tproxy echo.Instances // Headless echo app to be used by tests Headless echo.Instances // StatefulSet echo app to be used by tests StatefulSet echo.Instances // ProxylessGRPC echo app to be used by tests ProxylessGRPC echo.Instances
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 20 16:01:31 UTC 2024 - 6.1K bytes - Viewed (0) -
guava/src/com/google/common/collect/RegularContiguousSet.java
} }; } else { return super.createAsList(); } } @Override public int size() { long distance = domain.distance(first(), last()); return (distance >= Integer.MAX_VALUE) ? Integer.MAX_VALUE : (int) distance + 1; } @Override public boolean contains(@CheckForNull Object object) { if (object == null) { return false; } try {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 8.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/util/workloadinstances/index.go
defer i.mu.RUnlock() keys := i.ipToKeys[ip] if len(keys) == 0 { return nil } instances := make([]*model.WorkloadInstance, 0, len(keys)) for _, key := range sets.SortedList(keys) { if instance, exists := i.keyToInstance[key]; exists { instances = append(instances, instance) } } return instances } // Empty implements Index. func (i *index) Empty() bool { i.mu.RLock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 16 05:45:36 UTC 2023 - 4.1K bytes - Viewed (0) -
pkg/test/framework/components/echo/caller.go
Call(options CallOptions) (CallResult, error) CallOrFail(t test.Failer, options CallOptions) CallResult } type Callers []Caller // Instances returns an Instances if all callers are Instance, otherwise returns nil. func (c Callers) Instances() Instances { var out Instances for _, caller := range c { c, ok := caller.(Instance) if !ok { return nil } out = append(out, c) } return out
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 12 22:50:35 UTC 2022 - 1.3K bytes - Viewed (0)