Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 1,407 for distances (0.16 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top