- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 33 for KC (0.09 sec)
-
pkg/kubelet/apis/config/validation/validation.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 10 17:13:59 UTC 2024 - 18.2K bytes - Viewed (0) -
cmd/kubeadm/app/componentconfigs/kubelet.go
} func (kc *kubeletConfig) Get() interface{} { return &kc.config } func (kc *kubeletConfig) Set(cfg interface{}) { kc.config = *cfg.(*kubeletconfig.KubeletConfiguration) } func (kc *kubeletConfig) Default(cfg *kubeadmapi.ClusterConfiguration, _ *kubeadmapi.APIEndpoint, nodeRegOpts *kubeadmapi.NodeRegistrationOptions) { const kind = "KubeletConfiguration"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 8K bytes - Viewed (0) -
pkg/kubelet/apis/config/helpers.go
func KubeletConfigurationPathRefs(kc *KubeletConfiguration) []*string { paths := []*string{} paths = append(paths, &kc.StaticPodPath) paths = append(paths, &kc.Authentication.X509.ClientCAFile) paths = append(paths, &kc.TLSCertFile) paths = append(paths, &kc.TLSPrivateKeyFile) paths = append(paths, &kc.ResolverConfig) paths = append(paths, &kc.VolumePluginDir) paths = append(paths, &kc.PodLogsDir) return paths
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 17:55:59 UTC 2024 - 1.3K bytes - Viewed (0) -
pilot/pkg/config/kube/ingress/status.go
func NewStatusSyncer(meshHolder mesh.Watcher, kc kubelib.Client) *StatusSyncer { c := &StatusSyncer{ meshConfig: meshHolder, ingresses: kclient.NewFiltered[*knetworking.Ingress](kc, kclient.Filter{ObjectFilter: kc.ObjectFilter()}), ingressClasses: kclient.New[*knetworking.IngressClass](kc), pods: kclient.NewFiltered[*corev1.Pod](kc, kclient.Filter{ ObjectFilter: kc.ObjectFilter(),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 7.9K bytes - Viewed (0) -
pkg/kubelet/clustertrustbundle/clustertrustbundle_manager_test.go
"k8s.io/client-go/informers" "k8s.io/client-go/kubernetes/fake" "k8s.io/client-go/tools/cache" ) func TestBeforeSynced(t *testing.T) { kc := fake.NewSimpleClientset() informerFactory := informers.NewSharedInformerFactoryWithOptions(kc, 0) ctbInformer := informerFactory.Certificates().V1alpha1().ClusterTrustBundles() ctbManager, _ := NewInformerManager(ctbInformer, 256, 5*time.Minute)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 15.5K bytes - Viewed (0) -
cmd/kubelet/app/server.go
func InitializeTLS(kf *options.KubeletFlags, kc *kubeletconfiginternal.KubeletConfiguration) (*server.TLSOptions, error) { if !kc.ServerTLSBootstrap && kc.TLSCertFile == "" && kc.TLSPrivateKeyFile == "" { kc.TLSCertFile = filepath.Join(kf.CertDirectory, "kubelet.crt") kc.TLSPrivateKeyFile = filepath.Join(kf.CertDirectory, "kubelet.key") canReadCertAndKey, err := certutil.CanReadCertAndKey(kc.TLSCertFile, kc.TLSPrivateKeyFile)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:34 UTC 2024 - 53.9K bytes - Viewed (0) -
cni/pkg/install/kubeconfig.go
func maybeWriteKubeConfigFile(cfg *config.InstallConfig) error { kc, err := createKubeConfig(cfg) if err != nil { return err } if err := checkExistingKubeConfigFile(cfg, kc); err != nil { installLog.Info("kubeconfig either does not exist or is out of date, writing a new one")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 21:52:29 UTC 2024 - 4.8K bytes - Viewed (0) -
security/pkg/k8s/configutil_test.go
var objs []runtime.Object if tc.existingConfigMap != nil { objs = []runtime.Object{tc.existingConfigMap} } kc := kube.NewFakeClient(objs...) fake := kc.Kube().(*fake.Clientset) configmaps := kclient.New[*v1.ConfigMap](kc) if tc.clientMod != nil { tc.clientMod(fake) } kc.RunAndWait(test.NewStop(t)) fake.ClearActions() err := InsertDataToConfigMap(configmaps, tc.meta, tc.caBundle)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 08 21:58:25 UTC 2024 - 13K bytes - Viewed (0) -
cmd/kubeadm/app/componentconfigs/kubelet_unix.go
"k8s.io/utils/ptr" "k8s.io/kubernetes/cmd/kubeadm/app/util/initsystem" ) // Mutate allows applying pre-defined modifications to the config before it's marshaled. func (kc *kubeletConfig) Mutate() error { if err := mutateResolverConfig(&kc.config, isServiceActive); err != nil { return err } return nil } // mutateResolverConfig mutates the ResolverConfig in the kubeletConfig dynamically.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 25 10:26:46 UTC 2024 - 1.9K bytes - Viewed (0) -
pkg/webhooks/validation/controller/controller_test.go
}) return gatewayError } func TestGreenfield(t *testing.T) { controllerStop := make(chan struct{}) clientStop := test.NewStop(t) kc := kube.NewFakeClient() gatewayError := setupGatewayError(kc) c := unstartedTestController(kc) kc.RunAndWait(clientStop) go c.Run(controllerStop) webhooks := clienttest.Wrap(t, c.webhooks) fetch := func(name string) func() *admission.ValidatingWebhookConfiguration {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 05 03:21:04 UTC 2024 - 11.8K bytes - Viewed (0)