- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for NewIndex (0.12 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
guava/src/com/google/common/collect/MapMakerInternalMap.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sat May 18 03:24:34 UTC 2024 - 90.8K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/MapMakerInternalMap.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sat May 18 03:24:34 UTC 2024 - 90.8K bytes - Viewed (0)