Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for NewIndex (0.12 sec)

  1. pilot/pkg/config/monitor/monitor.go

    	oldLen := len(m.configs)
    	newLen := len(newConfigs)
    	oldIndex, newIndex := 0, 0
    	for oldIndex < oldLen && newIndex < newLen {
    		oldConfig := m.configs[oldIndex]
    		newConfig := newConfigs[newIndex]
    		if v := compareIDs(oldConfig, newConfig); v < 0 {
    			m.deleteConfig(oldConfig)
    			oldIndex++
    		} else if v > 0 {
    			m.createConfig(newConfig)
    			newIndex++
    		} else {
    			// version may change without content changing
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Feb 12 17:36:33 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  2. pkg/kube/krt/index.go

    func NewNamespaceIndex[I Namespacer](c Collection[I]) *Index[I, string] {
    	return NewIndex(c, func(o I) []string {
    		return []string{o.GetNamespace()}
    	})
    }
    
    // NewIndex creates a simple index, keyed by key K, over an informer for O. This is similar to
    // NewInformer.AddIndex, but is easier to use and can be added after an informer has already started.
    func NewIndex[I any, K comparable](
    	c Collection[I],
    	extract func(o I) []K,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 04:53:45 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  3. pkg/kube/krt/index_test.go

    	pc := clienttest.Wrap(t, kpc)
    	pods := krt.WrapClient[*corev1.Pod](kpc)
    	stop := test.NewStop(t)
    	c.RunAndWait(stop)
    	SimplePods := SimplePodCollection(pods)
    	tt := assert.NewTracker[string](t)
    	IPIndex := krt.NewIndex[SimplePod, string](SimplePods, func(o SimplePod) []string {
    		return []string{o.IP}
    	})
    	fetchSorted := func(ip string) []SimplePod {
    		return slices.SortBy(IPIndex.Lookup(ip), func(t SimplePod) string {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 09 19:55:53 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  4. pilot/pkg/serviceregistry/util/workloadinstances/index.go

    }
    
    // indexKey returns index key for a given workload instance.
    func indexKey(wi *model.WorkloadInstance) string {
    	return wi.Namespace + "/" + wi.Name
    }
    
    // NewIndex returns a new Index instance.
    func NewIndex() Index {
    	return &index{
    		keyFunc:       indexKey,
    		keyToInstance: make(map[string]*model.WorkloadInstance),
    		ipToKeys:      make(MultiValueMap),
    	}
    }
    
    // index implements Index.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 16 05:45:36 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex.go

    		ServiceEntries,
    		AllPolicies,
    		Namespaces,
    	)
    	WorkloadAddressIndex := krt.NewIndex[model.WorkloadInfo, networkAddress](Workloads, networkAddressFromWorkload)
    	WorkloadServiceIndex := krt.NewIndex[model.WorkloadInfo, string](Workloads, func(o model.WorkloadInfo) []string {
    		return maps.Keys(o.Services)
    	})
    	WorkloadWaypointIndex := krt.NewIndex[model.WorkloadInfo, networkAddress](Workloads, func(w model.WorkloadInfo) []networkAddress {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 19 17:19:41 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  6. pilot/pkg/serviceregistry/util/workloadinstances/index_test.go

    			ServiceAccount: spiffe.MustGenSpiffeURIForTrustDomain("cluster.local", "dns-selector", "default"),
    			TLSMode:        model.IstioMutualTLSModeLabel,
    		},
    	}
    
    	index := NewIndex()
    
    	// test update
    	index.Insert(wi1)
    	index.Insert(wi2)
    	index.Insert(wi3)
    
    	verifyGetByIP := func(ip string, expected []*model.WorkloadInstance) {
    		assert.Equal(t, expected, index.GetByIP(ip))
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 5K bytes
    - Viewed (0)
  7. pkg/controller/job/indexed_job_utils.go

    func (oi orderedIntervals) withOrderedIndexes(newIndexes []int) orderedIntervals {
    	newIndexIntervals := make(orderedIntervals, len(newIndexes))
    	for i, newIndex := range newIndexes {
    		newIndexIntervals[i] = interval{newIndex, newIndex}
    	}
    	return oi.merge(newIndexIntervals)
    }
    
    // with returns a new list of ordered intervals that contains the newOrderedIntervals.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 21 00:44:53 UTC 2023
    - 17.5K bytes
    - Viewed (0)
  8. src/compress/flate/deflate.go

    			// table.
    			if d.length <= d.fastSkipHashing {
    				var newIndex int
    				if d.fastSkipHashing != skipNever {
    					newIndex = d.index + d.length
    				} else {
    					newIndex = d.index + prevLength - 1
    				}
    				index := d.index
    				for index++; index < newIndex; index++ {
    					if index < d.maxInsertIndex {
    						hash := hash4(d.window[index : index+minMatchLength])
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 26 13:32:40 UTC 2024
    - 20.3K bytes
    - Viewed (0)
  9. guava/src/com/google/common/collect/MapMakerInternalMap.java

                int tailIndex = headIndex;
                for (E e = next; e != null; e = e.getNext()) {
                  int newIndex = e.getHash() & newMask;
                  if (newIndex != tailIndex) {
                    // The index changed. We'll need to copy the previous entry.
                    tailIndex = newIndex;
                    tail = e;
                  }
                }
                newTable.set(tailIndex, tail);
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Sat May 18 03:24:34 UTC 2024
    - 90.8K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

                int tailIndex = headIndex;
                for (E e = next; e != null; e = e.getNext()) {
                  int newIndex = e.getHash() & newMask;
                  if (newIndex != tailIndex) {
                    // The index changed. We'll need to copy the previous entry.
                    tailIndex = newIndex;
                    tail = e;
                  }
                }
                newTable.set(tailIndex, tail);
    
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Sat May 18 03:24:34 UTC 2024
    - 90.8K bytes
    - Viewed (0)
Back to top