- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 134 for configVals (0.27 sec)
-
internal/config/config.go
nc := c.Clone() for configName, configVals := range nc { for _, helpKV := range HelpSubSysMap[configName] { if helpKV.Sensitive { for name, kvs := range configVals { for i := range kvs { if kvs[i].Key == helpKV.Key && len(kvs[i].Value) > 0 { kvs[i].Value = "*redacted*" } } configVals[name] = kvs } } } } return nc }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 37.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/namespacecontroller_test.go
expectConfigMap(t, nc.configmaps, CACertNamespaceConfigMap, "selected", expectedData) expectConfigMapNotExist(t, nc.configmaps, "not-selected") meshWatcher.Update(&meshconfig.MeshConfig{ DiscoverySelectors: []*meshconfig.LabelSelector{{ MatchLabels: map[string]string{"kubernetes.io/metadata.name": "not-selected"}, }}, }, time.Second)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 8.1K bytes - Viewed (0) -
security/pkg/k8s/configutil_test.go
client.PrependReactor("get", "configmaps", func(action ktesting.Action) (bool, runtime.Object, error) { return true, &v1.ConfigMap{}, errors.NewNotFound(v1.Resource("configmaps"), configMapName) }) client.PrependReactor("create", "configmaps", func(action ktesting.Action) (bool, runtime.Object, error) { return true, &v1.ConfigMap{}, errors.NewAlreadyExists(v1.Resource("configmaps"), configMapName) }) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 08 21:58:25 UTC 2024 - 13K bytes - Viewed (0) -
pkg/kube/krt/informer_test.go
) func TestNewInformer(t *testing.T) { c := kube.NewFakeClient() ConfigMaps := krt.NewInformer[*corev1.ConfigMap](c) c.RunAndWait(test.NewStop(t)) cmt := clienttest.NewWriter[*corev1.ConfigMap](t, c) tt := assert.NewTracker[string](t) ConfigMaps.Register(TrackerHandler[*corev1.ConfigMap](tt)) assert.Equal(t, ConfigMaps.List(), nil) cmA := &corev1.ConfigMap{ ObjectMeta: metav1.ObjectMeta{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 16:38:40 UTC 2024 - 3.3K bytes - Viewed (0) -
pkg/kubelet/configmap/configmap_manager.go
// WARNING: Register/UnregisterPod functions should be efficient, // i.e. should not block on network operations. // RegisterPod registers all configmaps from a given pod. RegisterPod(pod *v1.Pod) // UnregisterPod unregisters configmaps from a given pod that are not // used by any other registered pod. UnregisterPod(pod *v1.Pod) } // simpleConfigMapManager implements ConfigMap Manager interface with
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 5.5K bytes - Viewed (0) -
pkg/controller/serviceaccount/legacy_serviceaccount_token_cleaner_test.go
LegacyTokenCleanUpPeriod: configuredLegacyTokenCleanUpPeriod("2022-12-28"), ExpectedActions: []core.Action{ core.NewGetAction(schema.GroupVersionResource{Version: "v1", Resource: "configmaps"}, metav1.NamespaceSystem, legacytokentracking.ConfigMapName), }, }, "configmap exists, but the configmap does not have tracked-since label": {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 03:52:06 UTC 2023 - 21.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/namespacecontroller.go
func (nc *NamespaceController) Run(stopCh <-chan struct{}) { if !kube.WaitForCacheSync("namespace controller", stopCh, nc.namespaces.HasSynced, nc.configmaps.HasSynced) { return } go nc.startCaBundleWatcher(stopCh) nc.queue.Run(stopCh) controllers.ShutdownAll(nc.configmaps, nc.namespaces) } // startCaBundleWatcher listens for updates to the CA bundle and update cm in each namespace
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 5.4K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/idempotency_test.go
client.PrependReactor("create", "configmaps", func(clientgotesting.Action) (bool, runtime.Object, error) { return true, nil, nil }) client.PrependReactor("get", "configmaps", func(clientgotesting.Action) (bool, runtime.Object, error) { return true, nil, nil }) client.PrependReactor("update", "configmaps", func(clientgotesting.Action) (bool, runtime.Object, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Feb 18 11:14:32 UTC 2024 - 33.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/meshconfig.go
cms := []*v1.ConfigMap{} if features.SharedMeshConfig != "" { cms = AppendNonNil(cms, krt.FetchOne(ctx, ConfigMaps, krt.FilterObjectName(types.NamespacedName{Name: features.SharedMeshConfig, Namespace: options.SystemNamespace}))) } cms = AppendNonNil(cms, krt.FetchOne(ctx, ConfigMaps, krt.FilterObjectName(types.NamespacedName{Name: cmName, Namespace: options.SystemNamespace}))) for _, c := range cms {
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.go
configMapLister: configMaps.Lister(), configMapSynced: configMaps.Informer().HasSynced, syncQueue: workqueue.NewTypedRateLimitingQueueWithConfig( workqueue.DefaultTypedControllerRateLimiter[string](), workqueue.TypedRateLimitingQueueConfig[string]{ Name: "bootstrap_signer_queue", }, ), } configMaps.Informer().AddEventHandlerWithResyncPeriod(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0)