- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 187 for configVals (0.15 sec)
-
pilot/pkg/status/distribution/state.go
})). Core().V1().ConfigMaps() c.cmInformer = i.Informer() c.cmHandle, _ = c.cmInformer.AddEventHandler(&DistroReportHandler{dc: c}) return c } func (c *Controller) Start(stop <-chan struct{}) { scope.Info("Starting status leader controller") // this will list all existing configmaps, as well as updates, right? go c.cmInformer.Run(stop)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7.7K bytes - Viewed (0) -
pkg/controlplane/storageversionhashdata/data.go
"authorization.k8s.io/v1/subjectaccessreviews", ) // GVRToStorageVersionHash shouldn't change unless we intentionally change the // storage version of a resource. var GVRToStorageVersionHash = map[string]string{ "v1/configmaps": "qFsyl6wFWjQ=", "v1/endpoints": "fWeeMqaN/OA=", "v1/events": "r2yiGXH7wu8=", "v1/limitranges": "EBKMFVe6cwo=", "v1/namespaces": "Q3oi5N2YM8M=",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 20:14:51 UTC 2024 - 4.9K bytes - Viewed (0) -
cluster/addons/rbac/cluster-loadbalancing/glbc/roles.yaml
apiVersion: rbac.authorization.k8s.io/v1 kind: Role metadata: name: system:controller:glbc namespace: kube-system labels: addonmanager.kubernetes.io/mode: Reconcile rules: - apiGroups: [""] resources: ["configmaps"] verbs: ["get", "list", "watch", "update", "create", "patch"] --- apiVersion: rbac.authorization.k8s.io/v1 kind: ClusterRole metadata: name: system:controller:glbc labels:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 15 13:39:59 UTC 2022 - 3.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/authentication/request/headerrequest/requestheader_controller_test.go
if err := indexer.Add(scenario.cm); err != nil { t.Fatal(err.Error()) } target := newDefaultTarget() target.configmapLister = corev1listers.NewConfigMapLister(indexer).ConfigMaps(defConfigMapNamespace) // act err := target.sync() if err != nil && !scenario.expectErr { t.Errorf("got unexpected error %v", err) } if err == nil && scenario.expectErr {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 07 14:37:01 UTC 2022 - 9.3K bytes - Viewed (0) -
cmd/kubeadm/app/phases/upgrade/postupgrade.go
var missingCoreDNSConfigMap bool if _, err := client.CoreV1().ConfigMaps(metav1.NamespaceSystem).Get( context.TODO(), kubeadmconstants.CoreDNSConfigMap, metav1.GetOptions{}, ); err != nil && apierrors.IsNotFound(err) { missingCoreDNSConfigMap = true } if missingCoreDNSConfigMap { klog.Warningf("the ConfigMaps %q in the namespace %q were not found. "+
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 10:21:20 UTC 2024 - 11.3K 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) -
pilot/pkg/leaderelection/k8sleaderelection/leaderelection_test.go
objectMeta.Annotations = map[string]string{ 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) -
pkg/config/mesh/kubemesh/watcher_test.go
key: "ingressClass: 1", }) setup := func(t test.Failer) (corev1.ConfigMapInterface, mesh.Watcher) { client := kube.NewFakeClient() cms := client.Kube().CoreV1().ConfigMaps(namespace) stop := test.NewStop(t) w := NewConfigMapWatcher(client, namespace, name, key, true, stop) AddUserMeshConfig(client, w, namespace, key, extraCmName, stop) client.RunAndWait(stop) return cms, w }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 7.7K 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) -
pkg/kube/watcher/configmapwatcher/configmapwatcher_test.go
} stop := make(chan struct{}) c := NewController(client, configMapNamespace, configMapName, callback) go c.Run(stop) kube.WaitForCacheSync("test", stop, c.HasSynced) cms := client.Kube().CoreV1().ConfigMaps(configMapNamespace) for i, step := range steps { resetCalled() t.Run(fmt.Sprintf("[%v]", i), func(t *testing.T) { g := NewWithT(t) switch { case step.added != nil:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 3.1K bytes - Viewed (0)