- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 77 for componentconfig (0.33 sec)
-
cmd/kube-controller-manager/app/discovery.go
controllerContext.InformerFactory.Discovery().V1().EndpointSlices(), controllerContext.ComponentConfig.EndpointSliceController.MaxEndpointsPerSlice, controllerContext.ClientBuilder.ClientOrDie("endpointslice-controller"), controllerContext.ComponentConfig.EndpointSliceController.EndpointUpdatesBatchPeriod.Duration, ).Run(ctx, int(controllerContext.ComponentConfig.EndpointSliceController.ConcurrentServiceEndpointSyncs)) return nil, true, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 11:28:02 UTC 2023 - 3.1K bytes - Viewed (0) -
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/kubeproxy_test.go
runKubeProxyFromTest(t, func(gvk schema.GroupVersionKind, yaml string) (kubeadmapi.ComponentConfig, error) { return kubeProxyHandler.FromDocumentMap(kubeadmapi.DocumentMap{ gvk: []byte(yaml), }) }) } func TestKubeProxyFromCluster(t *testing.T) { runKubeProxyFromTest(t, func(_ schema.GroupVersionKind, yaml string) (kubeadmapi.ComponentConfig, error) { client := clientsetfake.NewSimpleClientset(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 01 14:17:07 UTC 2022 - 5.2K 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-scheduler/app/config/config.go
kubeschedulerconfig "k8s.io/kubernetes/pkg/scheduler/apis/config" ) // Config has all the context to run a Scheduler type Config struct { // ComponentConfig is the scheduler server's configuration object. ComponentConfig kubeschedulerconfig.KubeSchedulerConfiguration // LoopbackClientConfig is a config for a privileged loopback connection LoopbackClientConfig *restclient.Config
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 24 09:38:49 UTC 2022 - 2.7K 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)