- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for gvkMap (0.1 sec)
-
staging/src/k8s.io/apiserver/pkg/cel/openapi/resolver/definitions.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 17:23:50 UTC 2023 - 3K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)