- Sort Score
- Result 10 results
- Languages All
Results 11 - 18 of 18 for gvkMap (0.12 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)