- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for InsertOrNew (0.21 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) -
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) -
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) -
tools/bug-report/pkg/bugreport/bugreport.go
proxyInfo, err := proxy.GetProxyInfo(client, istioNamespace) if err != nil { log.Error(err) continue } for _, pi := range *proxyInfo { sets.InsertOrNew(proxyVersionsMap, revision, pi.IstioVersion) } } for revision, vmap := range proxyVersionsMap { for v := range vmap { proxyVersions[revision] = append(proxyVersions[revision], v) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 05 20:57:29 UTC 2024 - 20.7K bytes - Viewed (0) -
pilot/pkg/model/push_context.go
// Use the value 0 as a sentinel indicating that one of the destinations // in the Virtual Service does not specify a port for this host. pn := 0 if port != nil { pn = int(port.Number) } sets.InsertOrNew(out, host, pn) } for _, h := range v.Http { for _, r := range h.Route { if r.Destination != nil { addDestination(r.Destination.Host, r.Destination.GetPort()) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 91.8K bytes - Viewed (0)