- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 237 for configMaps (0.29 sec)
-
cmd/kubeadm/app/util/config/cluster_test.go
staticPods []testresources.FakeStaticPod configMaps []testresources.FakeConfigMap newControlPlane bool expectedError bool }{ { name: "invalid - No kubeadm-config ConfigMap", expectedError: true, }, { name: "invalid - No ClusterConfiguration in kubeadm-config ConfigMap", configMaps: []testresources.FakeConfigMap{ {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 14 13:07:56 UTC 2024 - 26.7K 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) -
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) -
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) -
pilot/pkg/leaderelection/k8sleaderelection/leaderelection_test.go
rl.LeaderElectionRecordAnnotationKey: string(recordBytes), } } switch objectType { case "endpoints": obj = &corev1.Endpoints{ObjectMeta: objectMeta} case "configmaps": obj = &corev1.ConfigMap{ObjectMeta: objectMeta} case "leases": var spec coordinationv1.LeaseSpec if record != nil { spec = rl.LeaderElectionRecordToLeaseSpec(record) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jan 23 16:39:43 UTC 2023 - 42.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/apis/flowcontrol/bootstrap/default.go
// to ensure that those calls won't get caught by the following // <workload-leader-election> flow-schema. // // TODO(#80289): Get rid of this rule once we get rid of support for // using endpoints and configmaps objects for leader election. SuggestedFlowSchemaEndpointsController = newFlowSchema( "endpoint-controller", "workload-high", 150, flowcontrol.FlowDistinguisherMethodByUserType, flowcontrol.PolicyRulesWithSubjects{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 20.5K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/rbac/bootstrappolicy/testdata/cluster-roles.yaml
- deletecollection - patch - update - apiGroups: - "" resources: - pods/eviction verbs: - create - apiGroups: - "" resources: - configmaps - events - persistentvolumeclaims - replicationcontrollers - replicationcontrollers/scale - secrets - serviceaccounts - services - services/proxy verbs:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 08:11:08 UTC 2023 - 24.1K 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)