From 8b0294daed236dcaf2b2f74ad4a38405118ebbaa Mon Sep 17 00:00:00 2001 From: Marek Siarkowicz Date: Thu, 13 Mar 2025 11:55:23 +0100 Subject: [PATCH] Fix typo and pass the environment variable required to enable watchcache consistency checking in GCE tests --- cluster/gce/gci/configure-kubeapiserver.sh | 6 ++++++ cluster/gce/util.sh | 1 + .../src/k8s.io/apiserver/pkg/storage/cacher/delegator.go | 4 ++-- 3 files changed, 9 insertions(+), 2 deletions(-) diff --git a/cluster/gce/gci/configure-kubeapiserver.sh b/cluster/gce/gci/configure-kubeapiserver.sh index 1b4b5ad416c..77cae02a4fb 100644 --- a/cluster/gce/gci/configure-kubeapiserver.sh +++ b/cluster/gce/gci/configure-kubeapiserver.sh @@ -348,6 +348,12 @@ function start-kube-apiserver { fi container_env+="{\"name\": \"KUBE_LIST_FROM_CACHE_INCONSISTENCY_DETECTOR\", \"value\": \"${ENABLE_KUBE_LIST_FROM_CACHE_INCONSISTENCY_DETECTOR}\"}" fi + if [[ -n "${ENABLE_KUBE_WATCHCACHE_CONSISTENCY_CHECKER:-}" ]]; then + if [[ -n "${container_env}" ]]; then + container_env="${container_env}, " + fi + container_env+="{\"name\": \"KUBE_WATCHCACHE_CONSISTENCY_CHECKER\", \"value\": \"${ENABLE_KUBE_WATCHCACHE_CONSISTENCY_CHECKER}\"}" + fi if [[ -n "${ENABLE_PATCH_CONVERSION_DETECTOR:-}" ]]; then if [[ -n "${container_env}" ]]; then container_env="${container_env}, " diff --git a/cluster/gce/util.sh b/cluster/gce/util.sh index 8ed7c110d83..e619f4b890e 100755 --- a/cluster/gce/util.sh +++ b/cluster/gce/util.sh @@ -1197,6 +1197,7 @@ ENABLE_VOLUME_SNAPSHOTS: $(yaml-quote "${ENABLE_VOLUME_SNAPSHOTS:-}") ENABLE_APISERVER_ADVANCED_AUDIT: $(yaml-quote "${ENABLE_APISERVER_ADVANCED_AUDIT:-}") ENABLE_APISERVER_DYNAMIC_AUDIT: $(yaml-quote "${ENABLE_APISERVER_DYNAMIC_AUDIT:-}") ENABLE_CACHE_MUTATION_DETECTOR: $(yaml-quote "${ENABLE_CACHE_MUTATION_DETECTOR:-false}") +ENABLE_KUBE_WATCHCACHE_CONSISTENCY_CHECKER: $(yaml-quote "${ENABLE_KUBE_WATCHCACHE_CONSISTENCY_CHECKER:-false}") ENABLE_KUBE_WATCHLIST_INCONSISTENCY_DETECTOR: $(yaml-quote "${ENABLE_KUBE_WATCHLIST_INCONSISTENCY_DETECTOR:-false}") ENABLE_KUBE_LIST_FROM_CACHE_INCONSISTENCY_DETECTOR: $(yaml-quote "${ENABLE_KUBE_LIST_FROM_CACHE_INCONSISTENCY_DETECTOR:-false}") ENABLE_PATCH_CONVERSION_DETECTOR: $(yaml-quote "${ENABLE_PATCH_CONVERSION_DETECTOR:-false}") diff --git a/staging/src/k8s.io/apiserver/pkg/storage/cacher/delegator.go b/staging/src/k8s.io/apiserver/pkg/storage/cacher/delegator.go index 5c777305ae8..e8382caec36 100644 --- a/staging/src/k8s.io/apiserver/pkg/storage/cacher/delegator.go +++ b/staging/src/k8s.io/apiserver/pkg/storage/cacher/delegator.go @@ -49,12 +49,12 @@ var ( // List latency SLO (30 seconds) and timeout (1 minute). ConsistencyCheckPeriod = 5 * time.Minute // ConsistencyCheckerEnabled enables the consistency checking mechanism for cache. - // Based on KUBE_WATCHCACHE_CONSISTANCY_CHECKER environment variable. + // Based on KUBE_WATCHCACHE_CONSISTENCY_CHECKER environment variable. ConsistencyCheckerEnabled = false ) func init() { - ConsistencyCheckerEnabled, _ = strconv.ParseBool(os.Getenv("KUBE_WATCHCACHE_CONSISTANCY_CHECKER")) + ConsistencyCheckerEnabled, _ = strconv.ParseBool(os.Getenv("KUBE_WATCHCACHE_CONSISTENCY_CHECKER")) } func NewCacheDelegator(cacher *Cacher, storage storage.Interface) *CacheDelegator {