- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 585 for Keys (0.04 sec)
-
internal/store/batch.go
// Batch represents an ordered batch type Batch[K key, T any] struct { keys []K items map[K]T limit uint32 sync.Mutex } // Add adds the item to the batch func (b *Batch[K, T]) Add(key K, item T) error { b.Lock() defer b.Unlock() if b.isFull() { return ErrBatchFull } if _, ok := b.items[key]; !ok { b.keys = append(b.keys, key) } b.items[key] = item return nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Oct 07 15:07:38 UTC 2023 - 2.5K bytes - Viewed (0) -
pilot/pkg/xds/xds_cache_test.go
} }) t.Run("clear all", func(t *testing.T) { c := model.NewXdsCache() start := time.Now() c.Add(ep1, &model.PushRequest{Start: start}, any1) c.Add(ep2, &model.PushRequest{Start: start}, any2) c.ClearAll() if len(c.Keys(model.EDSType)) != 0 { t.Fatalf("expected no keys, got: %v", c.Keys(model.EDSType)) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Aug 31 20:43:08 UTC 2023 - 7.8K bytes - Viewed (0) -
pkg/controller/util/selectors/bimultimap.go
func (m *BiMultimap) Select(key Key) (keys []Key, ok bool) { m.mux.RLock() defer m.mux.RUnlock() selectingObject, ok := m.selectingObjects[key] if !ok { // Does not exist. return nil, false } keys = make([]Key, 0) if labeled, ok := m.labeledBySelecting[selectingObject.selectorKey]; ok { for _, labeledObject := range labeled.objects { keys = append(keys, labeledObject.key) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 21:41:32 UTC 2023 - 9.6K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/dsl/CapabilityNotationParserFactoryTest.groovy
[group: 'foo'] | "Required keys [name, version] are missing from map {group=foo}." [name: 'foo'] | "Required keys [group, version] are missing from map {name=foo}." [name: 'foo', version: 'v1'] | "Required keys [group] are missing from map {name=foo, version=v1}." [name: null] | "Required keys [group, name, version] are missing from map {name=null}." }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 4.8K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/TestMapEntrySetGenerator.java
this.keys = keys; this.values = values; } @Override public SampleElements<Entry<K, V>> samples() { return SampleElements.mapEntries(keys, values); } @Override public Set<Entry<K, V>> create(Object... elements) { Entry<K, V>[] entries = createArray(elements.length); System.arraycopy(elements, 0, entries, 0, elements.length);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Feb 26 19:46:10 UTC 2024 - 2.1K bytes - Viewed (0) -
src/expvar/expvar.go
return b } // Init removes all keys from the map. func (v *Map) Init() *Map { v.keysMu.Lock() defer v.keysMu.Unlock() v.keys = v.keys[:0] v.m.Clear() return v } // addKey updates the sorted list of keys in v.keys. func (v *Map) addKey(key string) { v.keysMu.Lock() defer v.keysMu.Unlock() // Using insertion sort to place key into the already-sorted v.keys.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 21:32:11 UTC 2024 - 9.1K bytes - Viewed (0) -
pkg/kube/krt/filter.go
listFromIndex func() any indexMatches func(any) bool } func (f *filter) String() string { attrs := []string{} if !f.keys.IsNil() { attrs = append(attrs, "keys="+f.keys.String()) } if f.selectsNonEmpty != nil { attrs = append(attrs, fmt.Sprintf("selectsNonEmpty=%v", f.selectsNonEmpty)) } if f.selects != nil { attrs = append(attrs, fmt.Sprintf("selects=%v", f.selects)) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 4.8K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/cache/lruexpirecache.go
// might return "not found". // // Keys are returned ordered from least recently used to most recently used. func (c *LRUExpireCache) Keys() []interface{} { c.lock.Lock() defer c.lock.Unlock() now := c.clock.Now() val := make([]interface{}, 0, c.evictionList.Len()) for element := c.evictionList.Back(); element != nil; element = element.Prev() { // Only return unexpired keys
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 4.3K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/CrossBuildInMemoryCacheFactory.java
* Note that this implementation should only be used to create global scoped services. * Note that this implementation currently retains strong references to keys and values during the whole lifetime of a build session. * * Uses a simple algorithm to collect unused values, by retaining strong references to all keys and values used during the current build session, and the previous build session.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/testdata/valid-configs/identity-first.yaml
name: testproviderv2 endpoint: unix:///tmp/testprovider.sock - aescbc: keys: - name: key1 secret: c2VjcmV0IGlzIHNlY3VyZQ== - name: key2 secret: dGhpcyBpcyBwYXNzd29yZA== - secretbox: keys: - name: key1
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 30 23:18:14 UTC 2023 - 903 bytes - Viewed (0)