Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for gvkMap (0.26 sec)

  1. staging/src/k8s.io/apiserver/pkg/cel/openapi/resolver/definitions.go

    	for _, gvkAny := range gvks {
    		// type check the map and all fields
    		gvkMap, ok := gvkAny.(map[string]any)
    		if !ok {
    			return nil
    		}
    		g, ok := gvkMap["group"].(string)
    		if !ok {
    			return nil
    		}
    		v, ok := gvkMap["version"].(string)
    		if !ok {
    			return nil
    		}
    		k, ok := gvkMap["kind"].(string)
    		if !ok {
    			return nil
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 17:23:50 UTC 2023
    - 3K bytes
    - Viewed (0)
  2. cmd/kubeadm/app/util/marshal_test.go

    	for _, rt := range tests {
    		t.Run(rt.name, func(t2 *testing.T) {
    
    			gvkmap, err := SplitYAMLDocuments(rt.fileContents)
    			if (err != nil) != rt.expectedErr {
    				t2.Errorf("expected error: %t, actual: %t", rt.expectedErr, err != nil)
    			}
    
    			if !reflect.DeepEqual(gvkmap, rt.gvkmap) {
    				t2.Errorf("expected gvkmap: %s\n\tactual: %s\n", rt.gvkmap, gvkmap)
    			}
    		})
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 29 05:14:21 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/typeconverter.go

    		// kind fields
    		if gvkMap, ok := gvk.(map[interface{}]interface{}); ok {
    			group, ok = gvkMap["group"].(string)
    			if !ok {
    				continue
    			}
    			version, ok = gvkMap["version"].(string)
    			if !ok {
    				continue
    			}
    			kind, ok = gvkMap["kind"].(string)
    			if !ok {
    				continue
    			}
    
    		} else if gvkMap, ok := gvk.(map[string]interface{}); ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 22:55:50 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  4. cmd/kubeadm/app/componentconfigs/configset_test.go

    	kind: KubeletConfiguration
    	`)
    	gvkmap, err := kubeadmutil.SplitYAMLDocuments([]byte(test))
    	if err != nil {
    		t.Fatalf("unexpected failure of SplitYAMLDocuments: %v", err)
    	}
    
    	clusterCfg := testClusterCfg()
    	if err = FetchFromDocumentMap(clusterCfg, gvkmap); err != nil {
    		t.Fatalf("FetchFromDocumentMap failed: %v", err)
    	}
    
    	if len(clusterCfg.ComponentConfigs) != len(gvkmap) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 01 14:17:07 UTC 2022
    - 2.8K bytes
    - Viewed (0)
  5. cmd/kubeadm/app/util/config/resetconfiguration.go

    	b, err := os.ReadFile(cfgPath)
    	if err != nil {
    		return nil, errors.Wrapf(err, "unable to read config from %q ", cfgPath)
    	}
    
    	gvkmap, err := kubeadmutil.SplitYAMLDocuments(b)
    	if err != nil {
    		return nil, err
    	}
    
    	return documentMapToResetConfiguration(gvkmap, false, opts.AllowExperimental, false, opts.SkipCRIDetect)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 05 12:41:16 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  6. cmd/kubeadm/app/util/config/joinconfiguration.go

    	b, err := os.ReadFile(cfgPath)
    	if err != nil {
    		return nil, errors.Wrapf(err, "unable to read config from %q ", cfgPath)
    	}
    
    	gvkmap, err := kubeadmutil.SplitYAMLDocuments(b)
    	if err != nil {
    		return nil, err
    	}
    
    	return documentMapToJoinConfiguration(gvkmap, false, false, false, opts.SkipCRIDetect)
    }
    
    // documentMapToJoinConfiguration takes a map between GVKs and YAML documents (as returned by SplitYAMLDocuments),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 05 12:41:16 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  7. cmd/kubeadm/app/util/config/upgradeconfiguration.go

    // finds a UpgradeConfiguration, decodes it, dynamically defaults it and then validates it prior to return.
    func documentMapToUpgradeConfiguration(gvkmap kubeadmapi.DocumentMap, allowDeprecated bool) (*kubeadmapi.UpgradeConfiguration, error) {
    	var internalcfg *kubeadmapi.UpgradeConfiguration
    
    	for gvk, bytes := range gvkmap {
    		// check if this version is supported and possibly not deprecated
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 11:04:08 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apimachinery/pkg/util/managedfields/gvkparser.go

    		// gvk extension list must be a map with group, version, and
    		// kind fields
    		gvkMap, ok := gvk.(map[interface{}]interface{})
    		if !ok {
    			continue
    		}
    		group, ok := gvkMap["group"].(string)
    		if !ok {
    			continue
    		}
    		version, ok := gvkMap["version"].(string)
    		if !ok {
    			continue
    		}
    		kind, ok := gvkMap["kind"].(string)
    		if !ok {
    			continue
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 05 18:56:48 UTC 2022
    - 3.6K bytes
    - Viewed (0)
  9. cmd/kubeadm/app/util/marshal.go

    		// Save the mapping between the gvk and the bytes that object consists of
    		gvkmap[*gvk] = b
    	}
    	if err := errorsutil.NewAggregate(errs); err != nil {
    		return nil, err
    	}
    	return gvkmap, nil
    }
    
    // GroupVersionKindsFromBytes parses the bytes and returns a gvk slice
    func GroupVersionKindsFromBytes(b []byte) ([]schema.GroupVersionKind, error) {
    	gvkmap, err := SplitYAMLDocuments(b)
    	if err != nil {
    		return nil, err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 29 05:14:21 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  10. cmd/kubeadm/app/util/config/common.go

    	newConfig := [][]byte{}
    
    	if mutators == nil {
    		mutators = defaultMigrateMutators()
    	}
    
    	gvkmap, err := kubeadmutil.SplitYAMLDocuments(oldConfig)
    	if err != nil {
    		return []byte{}, err
    	}
    
    	gvks := []schema.GroupVersionKind{}
    	for gvk := range gvkmap {
    		gvks = append(gvks, gvk)
    	}
    
    	if err := validateKnownGVKs(gvks); err != nil {
    		return []byte{}, err
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 11:04:08 UTC 2024
    - 18.1K bytes
    - Viewed (0)
Back to top