Should get ENABLE_CLIENT_GO_WATCH_LIST_ALPHA when new reflector

Signed-off-by: kkkkun <scuzk373x@gmail.com>

Kubernetes-commit: 2eed9b4143a9009b3327003ae50dbbebb44d2841
This commit is contained in:
kkkkun
2023-05-24 21:09:53 +08:00
committed by Kubernetes Publisher
parent 6fbb0bd42d
commit 3195e36899
2 changed files with 5 additions and 4 deletions

View File

@@ -18,7 +18,6 @@ package cache
import (
"errors"
"os"
"sync"
"time"
@@ -148,9 +147,6 @@ func (c *controller) Run(stopCh <-chan struct{}) {
if c.config.WatchErrorHandler != nil {
r.watchErrorHandler = c.config.WatchErrorHandler
}
if s := os.Getenv("ENABLE_CLIENT_GO_WATCH_LIST_ALPHA"); len(s) > 0 {
r.UseWatchList = true
}
c.reflectorMutex.Lock()
c.reflector = r