- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for InsertOrNew (0.17 sec)
-
pkg/util/sets/set.go
func (s Set[T]) String() string { return fmt.Sprintf("%v", s.UnsortedList()) } // InsertOrNew inserts t into the set if the set exists, or returns a new set with t if not. // Works well with DeleteCleanupLast. // Example: // // InsertOrNew(m, key, value) func InsertOrNew[K comparable, T comparable](m map[K]Set[T], k K, v T) { s, f := m[k] if !f { m[k] = New(v) } else {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 05:26:03 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/util/sets/set_test.go
b.StopTimer() s := New(sortOrder...) b.StartTimer() SortedList(s) } }) } func TestMapOfSet(t *testing.T) { m := map[int]String{} InsertOrNew(m, 1, "a") InsertOrNew(m, 1, "b") InsertOrNew(m, 2, "c") assert.Equal(t, m, map[int]String{1: New("a", "b"), 2: New("c")}) DeleteCleanupLast(m, 1, "a") assert.Equal(t, m, map[int]String{1: New("b"), 2: New("c")})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 05:26:03 UTC 2024 - 7.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/util/workloadinstances/map.go
// multiple values. type MultiValueMap map[string]sets.String // Insert adds given (key, value) pair into the map. func (m MultiValueMap) Insert(key, value string) MultiValueMap { sets.InsertOrNew(m, key, value) return m } // Delete removes given (key, value) pair out of the map. func (m MultiValueMap) Delete(key, value string) MultiValueMap { sets.DeleteCleanupLast(m, key, value) return m
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 08 02:49:42 UTC 2023 - 1.1K bytes - Viewed (0) -
pkg/kube/krt/index.go
sets.DeleteCleanupLast(idx.objects, indexKey, key) } } if o.New != nil { obj := *o.New key := GetKey(obj) for _, indexKey := range extract(obj) { sets.InsertOrNew(idx.objects, indexKey, key) } } }) return &idx
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/kclient/index.go
mu: sync.RWMutex{}, } addObj := func(obj any) { ro := controllers.ExtractObject(obj) o := ro.(O) objectKey := config.NamespacedName(o) for _, indexKey := range extract(o) { sets.InsertOrNew(idx.objects, indexKey, objectKey) } } deleteObj := func(obj any) { ro := controllers.ExtractObject(obj) o := ro.(O) objectKey := config.NamespacedName(o) for _, indexKey := range extract(o) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 04 03:49:30 UTC 2023 - 3.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod.go
return } if current, f := pc.IPByPods[key]; f { // The pod already exists, but with another IP Address. We need to clean up that sets.DeleteCleanupLast(pc.podsByIP, current, key) } sets.InsertOrNew(pc.podsByIP, ip, key) pc.IPByPods[key] = ip if endpointsToUpdate, f := pc.needResync[ip]; f { delete(pc.needResync, ip) for epKey := range endpointsToUpdate { pc.queueEndpointEvent(epKey) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 10.8K bytes - Viewed (0) -
pilot/pkg/networking/grpcgen/cds.go
filter := map[string]sets.String{} for _, name := range names { dir, _, hn, p := model.ParseSubsetKey(name) defaultKey := model.BuildSubsetKey(dir, "", hn, p) sets.InsertOrNew(filter, defaultKey, name) } return filter } // clusterBuilder is responsible for building a single default and subset clusters for a service // TODO re-use the v1alpha3.ClusterBuilder:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 9.2K bytes - Viewed (0) -
pilot/pkg/status/distribution/reporter.go
r.deleteKeyFromReverseMap(key) var version string if len(nonce) > 12 { version = nonce[:xds.VersionLen] } else { version = nonce } // touch r.status[key] = version sets.InsertOrNew(r.reverseStatus, version, key) } // This is a helper function for keeping our reverseStatus map in step with status. // must have write lock before calling. func (r *Reporter) deleteKeyFromReverseMap(key string) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 11.5K bytes - Viewed (0) -
pilot/pkg/model/typed_xds_cache.go
l.evictQueue = append(l.evictQueue, evictKeyConfigs[K]{k, v.dependentConfigs}) } func (l *lruCache[K]) updateConfigIndex(k K, dependentConfigs []ConfigHash) { for _, cfg := range dependentConfigs { sets.InsertOrNew(l.configIndex, cfg, k) } } func (l *lruCache[K]) clearConfigIndex(k K, dependentConfigs []ConfigHash) { c, exists := l.store.Get(k) if exists { newDependents := c.dependentConfigs
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 30 05:26:03 UTC 2024 - 11K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster.go
// So deletedClusters.Difference(builtClusters) would give us the correct deleted inbound clusters. deletedClusters.Insert(cluster) } else { if subset == "" { sets.InsertOrNew(serviceClusters, string(svcHost), cluster) } else { sets.InsertOrNew(subsetClusters, string(svcHost), cluster) } if servicePortClusters[string(svcHost)] == nil { servicePortClusters[string(svcHost)] = make(map[int]string) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0)