- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 119 for configMaps (0.47 sec)
-
pkg/controlplane/controller/clusterauthenticationtrust/cluster_authentication_trust_controller.go
_, err := configMapClient.ConfigMaps(required.Namespace).Update(context.TODO(), required, metav1.UpdateOptions{}) if apierrors.IsNotFound(err) { _, err := configMapClient.ConfigMaps(required.Namespace).Create(context.TODO(), required, metav1.CreateOptions{}) return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 18.2K bytes - Viewed (0) -
cmd/kubeadm/app/phases/upgrade/postupgrade.go
var errs []error // If the coredns ConfigMap is missing, show a warning and assume that the // DNS addon was skipped during "kubeadm init", and that its redeployment on upgrade is not desired. // // TODO: remove this once "kubeadm upgrade apply" phases are supported: // https://github.com/kubernetes/kubeadm/issues/1318 var missingCoreDNSConfigMap bool if _, err := client.CoreV1().ConfigMaps(metav1.NamespaceSystem).Get(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 10:21:20 UTC 2024 - 11.3K bytes - Viewed (0) -
pkg/test/framework/components/istio/configmap.go
} return cmName, nil } func (cm *configMap) getConfigMap(c cluster.Cluster, name string) (*corev1.ConfigMap, error) { return c.Kube().CoreV1().ConfigMaps(cm.namespace).Get(context.TODO(), name, metav1.GetOptions{}) } func (cm *configMap) updateConfigMap(c cluster.Cluster, cfgMap *corev1.ConfigMap) error { _, err := c.Kube().CoreV1().ConfigMaps(cm.namespace).Update(context.TODO(), cfgMap, metav1.UpdateOptions{})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 12.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/request/headerrequest/requestheader_controller.go
func (c *RequestHeaderAuthRequestController) sync() error { configMap, err := c.configmapLister.Get(c.configmapName) if err != nil { return err } return c.syncConfigMap(configMap) } func (c *RequestHeaderAuthRequestController) syncConfigMap(configMap *corev1.ConfigMap) error { hasChanged, newRequestHeaderBundle, err := c.hasRequestHeaderBundleChanged(configMap) if err != nil { return err } if hasChanged {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 10.9K bytes - Viewed (0) -
pkg/kube/krt/collection_test.go
Results := krt.NewCollection(pods, func(ctx krt.HandlerContext, i *corev1.Pod) *Result { foos := krt.Fetch(ctx, configMaps, krt.FilterLabel(lblFoo)) bars := krt.Fetch(ctx, configMaps, krt.FilterLabel(lblBar)) names := slices.Map(foos, func(f *corev1.ConfigMap) string { return f.Name }) names = append(names, slices.Map(bars, func(f *corev1.ConfigMap) string { return f.Name })...) names = slices.Sort(names) return &Result{ Named: NewNamed(i),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 04:22:19 UTC 2024 - 14.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex.go
XDSUpdater: options.XDSUpdater, Network: options.LookupNetwork, } filter := kclient.Filter{ ObjectFilter: options.Client.ObjectFilter(), } ConfigMaps := krt.NewInformerFiltered[*v1.ConfigMap](options.Client, filter, krt.WithName("ConfigMaps")) authzPolicies := kclient.NewDelayedInformer[*securityclient.AuthorizationPolicy](options.Client, gvr.AuthorizationPolicy, kubetypes.StandardInformer, filter)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 19 17:19:41 UTC 2024 - 15.8K bytes - Viewed (0) -
pilot/pkg/leaderelection/leaderelection_test.go
watcher := &fakeDefaultWatcher{} _, stop := createElection(t, "pod1", "", watcher, true, client) if err := client.CoreV1().ConfigMaps("ns").Delete(context.TODO(), testLock, metav1.DeleteOptions{}); err != nil { t.Fatal(err) } retry.UntilSuccessOrFail(t, func() error { l, err := client.CoreV1().ConfigMaps("ns").List(context.TODO(), metav1.ListOptions{}) if err != nil { return err } if len(l.Items) != 1 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 04:22:19 UTC 2024 - 11.4K bytes - Viewed (0) -
tests/integration/operator/switch_cr_test.go
} var err error // clean up dynamically created secret and configmaps if e := cs.Kube().CoreV1().Secrets(IstioNamespace).DeleteCollection( context.Background(), metav1.DeleteOptions{}, metav1.ListOptions{}); e != nil { err = multierror.Append(err, e) } if e := cs.Kube().CoreV1().ConfigMaps(IstioNamespace).DeleteCollection(
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 10 20:33:28 UTC 2024 - 17.5K bytes - Viewed (0) -
pkg/config/schema/kubeclient/resources.gen.go
} case gvr.ConfigMap: l = func(options metav1.ListOptions) (runtime.Object, error) { return c.Kube().CoreV1().ConfigMaps(opts.Namespace).List(context.Background(), options) } w = func(options metav1.ListOptions) (watch.Interface, error) { return c.Kube().CoreV1().ConfigMaps(opts.Namespace).Watch(context.Background(), options) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 13:57:51 UTC 2024 - 31.1K bytes - Viewed (0) -
cmd/kubeadm/app/phases/addons/dns/dns.go
if err != nil { return errors.Wrap(err, "unable to migrate CoreDNS ConfigMap") } // Take a copy of the existing Corefile data as `Corefile-backup` and update the ConfigMap if _, err := client.CoreV1().ConfigMaps(cm.ObjectMeta.Namespace).Update(context.TODO(), &v1.ConfigMap{ ObjectMeta: metav1.ObjectMeta{ Name: kubeadmconstants.CoreDNSConfigMap,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 10:21:20 UTC 2024 - 16.1K bytes - Viewed (0)