- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 44 for KC (0.4 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) -
pkg/kubelet/kubeletconfig/configfiles/configfiles_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 18 12:18:41 UTC 2023 - 7.2K 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) -
tests/fuzz/kube_ingress_fuzzer.go
return 1 } func newServiceLister(objects ...runtime.Object) (kclient.Client[*corev1.Service], func()) { kc := kube.NewFakeClient(objects...) stop := make(chan struct{}) kc.RunAndWait(stop) teardown := func() { close(stop) } return kclient.New[*corev1.Service](kc), teardown
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 15 16:18:19 UTC 2023 - 1.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) -
pkg/kubelet/apis/config/validation/validation_reserved_memory.go
func validateReservedMemoryConfiguration(kc *kubeletconfig.KubeletConfiguration) []error { if len(kc.ReservedMemory) == 0 { return nil } var errors []error numaTypeDuplicates := map[int32]map[v1.ResourceName]bool{} for _, reservedMemory := range kc.ReservedMemory { numaNode := reservedMemory.NumaNode if _, ok := numaTypeDuplicates[numaNode]; !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 18 13:31:31 UTC 2021 - 2.4K 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)