kubernetes
/
apiserver
mirror of https://github.com/kubernetes/apiserver.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix typo and pass the environment variable required to enable watchcache consistency checking in GCE tests 

Kubernetes-commit: 8b0294daed236dcaf2b2f74ad4a38405118ebbaa
This commit is contained in:
Marek Siarkowicz 2025-03-13 11:55:23 +01:00 committed by Kubernetes Publisher
parent 7b991eb8ee
commit 36c1a58d7e
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/storage/cacher/delegator.go
View File

@ -49,12 +49,12 @@ var (
// List latency SLO (30 seconds) and timeout (1 minute). // List latency SLO (30 seconds) and timeout (1 minute).
ConsistencyCheckPeriod = 5 * time.Minute ConsistencyCheckPeriod = 5 * time.Minute
// ConsistencyCheckerEnabled enables the consistency checking mechanism for cache. // 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 ConsistencyCheckerEnabled = false
) )
func init() { 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 { func NewCacheDelegator(cacher *Cacher, storage storage.Interface) *CacheDelegator {