- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 60 for componentconfig (0.58 sec)
-
cmd/kubeadm/app/componentconfigs/kubelet_windows.go
klog.V(2).Infoln("[componentconfig] Adapting the paths in the KubeletConfiguration for Windows...") // Get the drive from where the kubeadm binary was called. exe, err := os.Executable() if err != nil { return errors.Wrap(err, "could not obtain information about the kubeadm executable") } drive := filepath.VolumeName(filepath.Dir(exe)) klog.V(2).Infof("[componentconfig] Assuming Windows drive %q", drive)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 25 10:26:46 UTC 2024 - 3.1K bytes - Viewed (0) -
cmd/kubeadm/app/componentconfigs/configset.go
// CreateEmpty returns an empty kubeadmapi.ComponentConfig (not even defaulted) CreateEmpty func() kubeadmapi.ComponentConfig // fromCluster should load the component config from a config map on the cluster. // Don't use this directly! Use FromCluster instead! fromCluster func(*handler, clientset.Interface, *kubeadmapi.ClusterConfiguration) (kubeadmapi.ComponentConfig, error) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 04 15:36:00 UTC 2024 - 10.8K bytes - Viewed (0) -
cmd/kube-scheduler/app/options/options_test.go
Plugins: defaults.PluginsV1, PluginConfig: defaults.PluginConfigsV1, }, }, }, }, { name: "config file in componentconfig/v1alpha1", options: &Options{ ConfigFile: oldConfigFile, ComponentConfig: func() *kubeschedulerconfig.KubeSchedulerConfiguration { cfg, err := latest.Default() if err != nil { t.Fatal(err) } return cfg
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 13 07:42:19 UTC 2023 - 30.3K bytes - Viewed (0) -
cmd/kube-controller-manager/app/apps.go
flowcontrol.NewBackOff(1*time.Second, 15*time.Minute), ) if err != nil { return nil, true, fmt.Errorf("error creating DaemonSets controller: %v", err) } go dsc.Run(ctx, int(controllerContext.ComponentConfig.DaemonSetController.ConcurrentDaemonSetSyncs)) return nil, true, nil } func newStatefulSetControllerDescriptor() *ControllerDescriptor { return &ControllerDescriptor{ name: names.StatefulSetController,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 4.5K bytes - Viewed (0) -
cmd/kubeadm/app/componentconfigs/kubelet_test.go
runKubeletFromTest(t, func(gvk schema.GroupVersionKind, yaml string) (kubeadmapi.ComponentConfig, error) { return kubeletHandler.FromDocumentMap(kubeadmapi.DocumentMap{ gvk: []byte(yaml), }) }) } func TestKubeletFromCluster(t *testing.T) { runKubeletFromTest(t, func(_ schema.GroupVersionKind, yaml string) (kubeadmapi.ComponentConfig, error) { client := clientsetfake.NewSimpleClientset( testKubeletConfigMap(yaml),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 25 10:26:46 UTC 2024 - 9.6K bytes - Viewed (0) -
cmd/kube-controller-manager/app/batch.go
controllerContext.ClientBuilder.ClientOrDie("job-controller"), ) if err != nil { return nil, true, fmt.Errorf("creating Job controller: %v", err) } go jobController.Run(ctx, int(controllerContext.ComponentConfig.JobController.ConcurrentJobSyncs)) return nil, true, nil } func newCronJobControllerDescriptor() *ControllerDescriptor { return &ControllerDescriptor{ name: names.CronJobController,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 11:28:02 UTC 2023 - 2.5K bytes - Viewed (0) -
cmd/kubeadm/app/componentconfigs/fakeconfig_test.go
CreateEmpty: func() kubeadmapi.ComponentConfig { return &clusterConfig{ configBase: configBase{ GroupVersion: kubeadmapiv1.SchemeGroupVersion, }, } }, fromCluster: clusterConfigFromCluster, } func clusterConfigFromCluster(h *handler, clientset clientset.Interface, _ *kubeadmapi.ClusterConfiguration) (kubeadmapi.ComponentConfig, error) {
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/componentconfigs/kubelet.go
CreateEmpty: func() kubeadmapi.ComponentConfig { return &kubeletConfig{ configBase: configBase{ GroupVersion: kubeletconfig.SchemeGroupVersion, }, } }, fromCluster: kubeletConfigFromCluster, } func kubeletConfigFromCluster(h *handler, clientset clientset.Interface, _ *kubeadmapi.ClusterConfiguration) (kubeadmapi.ComponentConfig, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 8K bytes - Viewed (0) -
cmd/cloud-controller-manager/nodeipamcontroller.go
var secondaryServiceCIDR *net.IPNet // should we start nodeIPAM if !ccmConfig.ComponentConfig.KubeCloudShared.AllocateNodeCIDRs { return nil, false, nil } // Cannot run cloud ipam controller if cloud provider is nil (--cloud-provider not set or set to 'external') if cloud == nil && ccmConfig.ComponentConfig.KubeCloudShared.CIDRAllocatorType == string(ipam.CloudAllocatorType) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Oct 14 19:06:22 UTC 2023 - 8.9K bytes - Viewed (0) -
cmd/kube-scheduler/app/server_test.go
} if tc.wantLeaderElection != nil { gotLeaderElection := opts.ComponentConfig.LeaderElection if diff := cmp.Diff(*tc.wantLeaderElection, gotLeaderElection); diff != "" { t.Errorf("Unexpected leaderElection diff (-want, +got): %s", diff) } } if tc.wantClientConnection != nil { gotClientConnection := opts.ComponentConfig.ClientConnection
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 14.2K bytes - Viewed (0)