Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 18 of 18 for gvkMap (0.1 sec)

  1. cmd/kubeadm/app/util/config/common_test.go

    	var tcases = []struct {
    		name     string
    		gvkmap   kubeadmapi.DocumentMap
    		expected bool
    	}{
    		{
    			name: " Wrong Group value",
    			gvkmap: kubeadmapi.DocumentMap{
    				{Group: "foo.k8s.io", Version: "v1", Kind: "Foo"}: []byte(`kind: Foo`),
    			},
    			expected: false,
    		},
    		{
    			name: "Empty Group value",
    			gvkmap: kubeadmapi.DocumentMap{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 29 05:14:21 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  2. cmd/kubeadm/app/util/config/initconfiguration.go

    	gvkmap, err := kubeadmutil.SplitYAMLDocuments(b)
    	if err != nil {
    		return nil, err
    	}
    
    	return documentMapToInitConfiguration(gvkmap, false, false, false, skipCRIDetect)
    }
    
    // documentMapToInitConfiguration converts a map of GVKs and YAML documents to defaulted and validated configuration object.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 05 12:41:16 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  3. pkg/scheduler/eventhandlers_test.go

    func TestAddAllEventHandlers(t *testing.T) {
    	tests := []struct {
    		name                   string
    		gvkMap                 map[framework.GVK]framework.ActionType
    		expectStaticInformers  map[reflect.Type]bool
    		expectDynamicInformers map[schema.GroupVersionResource]bool
    	}{
    		{
    			name:   "default handlers in framework",
    			gvkMap: map[framework.GVK]framework.ActionType{},
    			expectStaticInformers: map[reflect.Type]bool{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 10 14:38:54 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  4. pkg/scheduler/scheduler.go

    	gvkMap := make(map[framework.GVK]framework.ActionType)
    	for _, queueingHints := range queueingHintsPerProfile {
    		for evt := range queueingHints {
    			if _, ok := gvkMap[evt.Resource]; ok {
    				gvkMap[evt.Resource] |= evt.ActionType
    			} else {
    				gvkMap[evt.Resource] = evt.ActionType
    			}
    		}
    	}
    	return gvkMap
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 20.8K bytes
    - Viewed (0)
  5. cmd/kubeadm/app/componentconfigs/fakeconfig_test.go

    		}
    
    		gvkmap, err := kubeadmutil.SplitYAMLDocuments([]byte(validUnmarshallableClusterConfig.yaml))
    		if err != nil {
    			t.Fatalf("unexpected failure of SplitYAMLDocuments: %v", err)
    		}
    
    		got := &clusterConfig{
    			configBase: configBase{
    				GroupVersion: kubeadmapiv1.SchemeGroupVersion,
    			},
    		}
    		if err = got.Unmarshal(gvkmap); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 04 15:36:00 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  6. cmd/kubeadm/app/cmd/config_test.go

    				t.Fatalf("Error from running the print command: %v", err)
    			}
    
    			gvkmap, err := kubeadmutil.SplitYAMLDocuments(output.Bytes())
    			if err != nil {
    				t.Fatalf("unexpected failure of SplitYAMLDocuments: %v", err)
    			}
    
    			gotKinds := []string{}
    			for gvk := range gvkmap {
    				gotKinds = append(gotKinds, gvk.Kind)
    			}
    
    			sort.Strings(gotKinds)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 06:58:01 UTC 2024
    - 13K bytes
    - Viewed (0)
  7. cmd/kubeadm/app/componentconfigs/configset.go

    	}
    
    	gvkmap, err := kubeadmutil.SplitYAMLDocuments([]byte(configData))
    	if err != nil {
    		return nil, err
    	}
    
    	// If the checksum comes up neatly we assume the config was generated
    	generatedConfig := VerifyConfigMapSignature(configMap)
    
    	componentCfg, err := h.FromDocumentMap(gvkmap)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 04 15:36:00 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  8. pkg/scheduler/eventhandlers.go

    // to add event handlers for various informers.
    func addAllEventHandlers(
    	sched *Scheduler,
    	informerFactory informers.SharedInformerFactory,
    	dynInformerFactory dynamicinformer.DynamicSharedInformerFactory,
    	gvkMap map[framework.GVK]framework.ActionType,
    ) error {
    	var (
    		handlerRegistration cache.ResourceEventHandlerRegistration
    		err                 error
    		handlers            []cache.ResourceEventHandlerRegistration
    	)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:21:04 UTC 2024
    - 24K bytes
    - Viewed (0)
Back to top