- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 55 for KC (0.01 sec)
-
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) -
src/internal/types/testdata/fixedbugs/issue50755.go
// during constraint type inference. func f4[M4 map[K4]int, K4 comparable](m4 M4) {} func f5[M5 map[K5]int, K5 comparable](m5 M5) { f4(m5) } // test case from issue func Copy[MC ~map[KC]VC, KC comparable, VC any](dst, src MC) { for k, v := range src { dst[k] = v } } func Merge[MM ~map[KM]VM, KM comparable, VM any](ms ...MM) MM { result := MM{} for _, m := range ms { Copy(result, m) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 02 02:58:32 UTC 2022 - 1K 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) -
pkg/kubelet/kubeletconfig/configfiles/configfiles.go
return nil, fmt.Errorf("kubelet config file %q was empty", loader.kubeletFile) } kc, err := utilcodec.DecodeKubeletConfiguration(loader.kubeletCodecs, data) if err != nil { return nil, err } // make all paths absolute resolveRelativePaths(kubeletconfig.KubeletConfigurationPathRefs(kc), filepath.Dir(loader.kubeletFile)) return kc, nil } func (loader *fsLoader) LoadIntoJSON() ([]byte, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 10 17:13:59 UTC 2024 - 3.7K bytes - Viewed (0) -
operator/pkg/helmreconciler/prune_test.go
}) t.Run("non-exist", func(t *testing.T) { cl := fake.NewClientBuilder().WithInterceptorFuncs(interceptorFunc).Build() iop := &v1alpha1.IstioOperator{} kc := kube.NewFakeClientWithVersion("24") h := &HelmReconciler{ client: cl, kubeClient: kc, opts: &Options{ ProgressLog: progress.NewLog(), Log: clog.NewDefaultLogger(), }, iop: iop, countLock: &sync.Mutex{},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 15 12:13:37 UTC 2023 - 5.2K bytes - Viewed (0) -
pkg/controller/deployment/recreate_test.go
} } kc := fake.NewSimpleClientset(expected...) informers := informers.NewSharedInformerFactory(kc, controller.NoResyncPeriodFunc()) _, ctx := ktesting.NewTestContext(t) c, err := NewDeploymentController(ctx, informers.Apps().V1().Deployments(), informers.Apps().V1().ReplicaSets(), informers.Core().V1().Pods(), kc) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 08 09:10:50 UTC 2023 - 5.9K bytes - Viewed (0) -
cmd/kubeadm/app/componentconfigs/kubelet_windows.go
"k8s.io/klog/v2" kubeletconfig "k8s.io/kubelet/config/v1beta1" "k8s.io/utils/ptr" ) // Mutate modifies absolute path fields in the KubeletConfiguration to be Windows compatible absolute paths. func (kc *kubeletConfig) Mutate() error { // When "kubeadm join" downloads the KubeletConfiguration from the cluster on Windows // nodes, it would contain absolute paths that may lack drive letters, since the config
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 25 10:26:46 UTC 2024 - 3.1K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/gatewayclass.go
queue controllers.Queue classes kclient.Client[*gateway.GatewayClass] } func NewClassController(kc kube.Client) *ClassController { gc := &ClassController{} gc.queue = controllers.NewQueue("gateway class", controllers.WithReconciler(gc.Reconcile), controllers.WithMaxAttempts(25)) gc.classes = kclient.New[*gateway.GatewayClass](kc)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 07 20:48:23 UTC 2024 - 4K bytes - Viewed (0)