github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-14 06:15:45 +00:00
Code Issues Projects Releases Wiki Activity

Should get ENABLE_CLIENT_GO_WATCH_LIST_ALPHA when new reflector

Browse Source 
Signed-off-by: kkkkun <scuzk373x@gmail.com>
This commit is contained in:
kkkkun 2023-05-24 21:09:53 +08:00
parent badcf9ab46
commit 2eed9b4143
2 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
staging/src/k8s.io/client-go/tools/cache/controller.go vendored
View File

@ -18,7 +18,6 @@ package cache
import ( import (
"errors" "errors"
"os"
"sync" "sync"
"time" "time"
@ -148,9 +147,6 @@ func (c *controller) Run(stopCh <-chan struct{}) {
if c.config.WatchErrorHandler != nil { if c.config.WatchErrorHandler != nil {
r.watchErrorHandler = c.config.WatchErrorHandler 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.reflectorMutex.Lock()
c.reflector = r c.reflector = r

5
staging/src/k8s.io/client-go/tools/cache/reflector.go vendored
View File

@ -22,6 +22,7 @@ import (
"fmt" "fmt"
"io" "io"
"math/rand" "math/rand"
"os"
"reflect" "reflect"
"strings" "strings"
"sync" "sync"
@ -239,6 +240,10 @@ func NewReflectorWithOptions(lw ListerWatcher, expectedType interface{}, store S
r.expectedGVK = getExpectedGVKFromObject(expectedType) r.expectedGVK = getExpectedGVKFromObject(expectedType)
} }
if s := os.Getenv("ENABLE_CLIENT_GO_WATCH_LIST_ALPHA"); len(s) > 0 {
r.UseWatchList = true
}
return r return r
} }