Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for StringKeySet (0.44 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. pkg/proxy/nftables/proxier_test.go

    	expectedStaleChains := sets.NewString("service-4AT6LBPK-ns3/svc3/tcp/p80", "endpoint-SWWHDC7X-ns3/svc3/tcp/p80__10.0.3.2/80", "endpoint-TQ2QKHCZ-ns3/svc3/tcp/p80__10.0.3.3/80")
    	gotStaleChains := sets.StringKeySet(fp.staleChains)
    	if !expectedStaleChains.Equal(gotStaleChains) {
    		t.Errorf("expected stale chains %v, got %v", expectedStaleChains, gotStaleChains)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 173.5K bytes
    - Viewed (0)
Back to top