Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for StringKeySet (0.14 sec)

  1. staging/src/k8s.io/apimachinery/pkg/util/sets/string.go

    // NewString creates a String from a list of values.
    func NewString(items ...string) String {
    	return String(New[string](items...))
    }
    
    // StringKeySet creates a String from a keys of a map[string](? extends interface{}).
    // If the value passed in is not actually a map, this will panic.
    func StringKeySet[T any](theMap map[string]T) String {
    	return String(KeySet(theMap))
    }
    
    // Insert adds items to the set.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 20 03:47:18 UTC 2022
    - 4K bytes
    - Viewed (0)
  2. plugin/pkg/auth/authorizer/rbac/bootstrappolicy/policy_test.go

    	list := &api.List{}
    	names := sets.NewString()
    	roles := map[string]runtime.Object{}
    
    	namespaceRoles := bootstrappolicy.NamespaceRoles()
    	for _, namespace := range sets.StringKeySet(namespaceRoles).List() {
    		bootstrapRoles := namespaceRoles[namespace]
    		for i := range bootstrapRoles {
    			role := bootstrapRoles[i]
    			names.Insert(role.Name)
    			roles[role.Name] = &role
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 15:45:31 UTC 2023
    - 9.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/deleted_kinds.go

    	versionsToRemove := sets.NewString()
    	for apiVersion := range sets.StringKeySet(versionedResourcesStorageMap) {
    		versionToResource := versionedResourcesStorageMap[apiVersion]
    		resourcesToRemove := sets.NewString()
    		for resourceName, resourceServingInfo := range versionToResource {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 16 03:02:49 UTC 2022
    - 7.6K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apimachinery/pkg/util/sets/set_test.go

    			b.ReportAllocs()
    			for i := 0; i < b.N; i++ {
    				makeSet()
    			}
    		})
    
    		b.Run(fmt.Sprintf("key-set-%v", here.size), func(b *testing.B) {
    			b.ReportAllocs()
    			for i := 0; i < b.N; i++ {
    				StringKeySet(randOperand())
    			}
    		})
    
    		b.Run(fmt.Sprintf("has-%v", here.size), func(b *testing.B) {
    			b.ReportAllocs()
    			for i := 0; i < b.N; i++ {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 20 03:47:18 UTC 2022
    - 8K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/server/mux/pathrecorder.go

    	}
    	if m.notFoundHandler != nil {
    		newMux.notFoundHandler = m.notFoundHandler
    	}
    	for path, handler := range m.pathToHandler {
    		newMux.pathToHandler[path] = handler
    	}
    
    	keys := sets.StringKeySet(m.prefixToHandler).List()
    	sort.Sort(sort.Reverse(byPrefixPriority(keys)))
    	for _, prefix := range keys {
    		newMux.prefixHandlers = append(newMux.prefixHandlers, prefixHandler{
    			prefix:  prefix,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 01:52:15 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  6. pkg/controlplane/instance_test.go

    			}
    			count++
    		}
    	}
    	if count != len(storageversionhashdata.GVRToStorageVersionHash) {
    		knownResources := sets.StringKeySet(storageversionhashdata.GVRToStorageVersionHash)
    		t.Errorf("please remove the redundant entries from GVRToStorageVersionHash: %v", knownResources.Difference(apiResources).List())
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 03 11:50:04 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/controller_test.go

    	}
    	return ctr.cqs.countActive == 0
    }
    
    func (cts *ctlrTestState) getQueueSetNames() sets.String {
    	cts.lock.Lock()
    	defer cts.lock.Unlock()
    	return sets.StringKeySet(cts.queues)
    }
    
    func (cts *ctlrTestState) getNonIdleQueueSetNames() sets.String {
    	cts.lock.Lock()
    	defer cts.lock.Unlock()
    	ans := sets.NewString()
    	for name, qs := range cts.queues {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:40 UTC 2023
    - 18.4K bytes
    - Viewed (0)
  8. cmd/kube-controller-manager/app/controllermanager.go

    func (r *ControllerDescriptor) RequiresSpecialHandling() bool {
    	return r.requiresSpecialHandling
    }
    
    // KnownControllers returns all known controllers's name
    func KnownControllers() []string {
    	return sets.StringKeySet(NewControllerDescriptors()).List()
    }
    
    // ControllerAliases returns a mapping of aliases to canonical controller names
    func ControllerAliases() map[string]string {
    	aliases := map[string]string{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 01 13:03:53 UTC 2024
    - 37.5K bytes
    - Viewed (0)
  9. pkg/controller/garbagecollector/graph_builder.go

    	oldUIDToRef := make(map[string]metav1.OwnerReference)
    	for _, value := range old {
    		oldUIDToRef[string(value.UID)] = value
    	}
    	oldUIDSet := sets.StringKeySet(oldUIDToRef)
    	for _, value := range new {
    		newUID := string(value.UID)
    		if oldUIDSet.Has(newUID) {
    			if !reflect.DeepEqual(oldUIDToRef[newUID], value) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apimachinery/pkg/util/strategicpatch/patch_test.go

    	}
    	schemas := []LookupPatchMeta{
    		mergeItemStructSchema,
    		mergeItemOpenapiSchema,
    		mergeItemOpenapiV3Schema,
    	}
    
    	for _, k := range sets.StringKeySet(testcases).List() {
    		t.Run(k, func(t *testing.T) {
    			tc := testcases[k]
    			for _, schema := range schemas {
    				t.Run(schema.Name()+"/TwoWay", func(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 16:45:45 UTC 2023
    - 130.4K bytes
    - Viewed (0)
Back to top