- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 797 for configmap3 (5.29 sec)
-
cmd/kubeadm/app/util/apiclient/idempotency.go
ctx := context.Background() configMap, err := client.CoreV1().ConfigMaps(meta.Namespace).Get(ctx, meta.Name, metav1.GetOptions{}) if err != nil { return errors.Wrap(err, "unable to get ConfigMap") } if err = mutator(configMap); err != nil { return errors.Wrap(err, "unable to mutate ConfigMap") } _, err = client.CoreV1().ConfigMaps(configMap.ObjectMeta.Namespace).Update(ctx, configMap, metav1.UpdateOptions{})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Feb 18 11:14:32 UTC 2024 - 18.4K bytes - Viewed (0) -
cluster/addons/fluentd-gcp/fluentd-gcp-configmap-old.yaml
# This ConfigMap is used to ingest logs against old resources like # "gke_container" and "gce_instance" when $LOGGING_STACKDRIVER_RESOURCE_TYPES is # set to "old". # When $LOGGING_STACKDRIVER_RESOURCE_TYPES is set to "new", the ConfigMap in # fluentd-gcp-configmap.yaml will be used for ingesting logs against new # resources like "k8s_container" and "k8s_node". kind: ConfigMap apiVersion: v1 data: containers.input.conf: |-
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 26 07:09:07 UTC 2018 - 16.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/meshconfig.go
func MeshConfigCollection(ConfigMaps krt.Collection[*v1.ConfigMap], options Options) krt.Singleton[MeshConfig] { cmName := "istio" if options.Revision != "" && options.Revision != "default" { cmName = cmName + "-" + options.Revision } return krt.NewSingleton[MeshConfig]( func(ctx krt.HandlerContext) *MeshConfig { meshCfg := mesh.DefaultMeshConfig() cms := []*v1.ConfigMap{} if features.SharedMeshConfig != "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 2.2K bytes - Viewed (0) -
pkg/controller/bootstrap/bootstrapsigner_test.go
secrets := informers.Core().V1().Secrets() configMaps := informers.Core().V1().ConfigMaps() bsc, err := NewSigner(cl, secrets, configMaps, options) if err != nil { return nil, nil, nil, nil, err } return bsc, cl, secrets, configMaps, nil } func newConfigMap(tokenID, signature string) *v1.ConfigMap { ret := &v1.ConfigMap{ ObjectMeta: metav1.ObjectMeta{ Namespace: metav1.NamespacePublic,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 00:05:53 UTC 2023 - 4.7K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/rbac/bootstrappolicy/namespace_policy.go
// role for the leader locking on supplied configmap ObjectMeta: metav1.ObjectMeta{Name: "system::leader-locking-kube-controller-manager"}, Rules: []rbacv1.PolicyRule{ rbacv1helpers.NewRule("watch").Groups(legacyGroup).Resources("configmaps").RuleOrDie(), rbacv1helpers.NewRule("get", "update").Groups(legacyGroup).Resources("configmaps").Names("kube-controller-manager").RuleOrDie(), }, })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 16 11:54:27 UTC 2020 - 7.4K bytes - Viewed (0) -
pkg/controller/certificates/rootcacertpublisher/publisher.go
_, err = c.client.CoreV1().ConfigMaps(ns).Update(ctx, cm, metav1.UpdateOptions{}) return err } func convertToCM(obj interface{}) (*v1.ConfigMap, error) { cm, ok := obj.(*v1.ConfigMap) if !ok { tombstone, ok := obj.(cache.DeletedFinalStateUnknown) if !ok { return nil, fmt.Errorf("couldn't get object from tombstone %#v", obj) } cm, ok = tombstone.Obj.(*v1.ConfigMap) if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.8K bytes - Viewed (0) -
pkg/registry/core/configmap/storage/storage.go
NewListFunc: func() runtime.Object { return &api.ConfigMapList{} }, PredicateFunc: configmap.Matcher, DefaultQualifiedResource: api.Resource("configmaps"), SingularQualifiedResource: api.Resource("configmap"), CreateStrategy: configmap.Strategy, UpdateStrategy: configmap.Strategy, DeleteStrategy: configmap.Strategy,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 20:38:11 UTC 2023 - 2.3K bytes - Viewed (0) -
pkg/kube/inject/watcher.go
cms := w.client.Kube().CoreV1().ConfigMaps(w.namespace) cm, err := cms.Get(context.TODO(), w.name, metav1.GetOptions{}) if err != nil { return nil, "", err } return readConfigMap(cm, w.configKey, w.valuesKey) } func (w *configMapWatcher) SetHandler(handler func(*Config, string) error) { w.handler = handler } func readConfigMap(cm *v1.ConfigMap, configKey, valuesKey string) (*Config, string, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/kube/krt/singleton_test.go
c := kube.NewFakeClient() ConfigMaps := krt.NewInformer[*corev1.ConfigMap](c) stop := test.NewStop(t) c.RunAndWait(stop) cmt := clienttest.NewWriter[*corev1.ConfigMap](t, c) ConfigMapNames := krt.NewSingleton[string]( func(ctx krt.HandlerContext) *string { cms := krt.Fetch(ctx, ConfigMaps) return ptr.Of(slices.Join(",", slices.Map(cms, func(c *corev1.ConfigMap) string { return config.NamespacedName(c).String()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 11 08:27:29 UTC 2024 - 2.9K bytes - Viewed (0) -
cmd/kubeadm/app/phases/uploadconfig/uploadconfig.go
fmt.Printf("[upload-config] Storing the configuration used in ConfigMap %q in the %q Namespace\n", kubeadmconstants.KubeadmConfigConfigMap, metav1.NamespaceSystem) // Prepare the ClusterConfiguration for upload // The components store their config in their own ConfigMaps, then reset the .ComponentConfig struct;
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 04 07:20:43 UTC 2023 - 4.4K bytes - Viewed (0)