Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for InsertOrNew (0.17 sec)

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