File tree Expand file tree Collapse file tree 1 file changed +4
-0
lines changed
staging/src/k8s.io/client-go/tools/cache Expand file tree Collapse file tree 1 file changed +4
-0
lines changed Original file line number Diff line number Diff line change @@ -72,6 +72,9 @@ type Config struct {
72
72
73
73
// Called whenever the ListAndWatch drops the connection with an error.
74
74
WatchErrorHandler WatchErrorHandler
75
+
76
+ // WatchListPageSize is the requested chunk size of initial and relist watch lists.
77
+ WatchListPageSize int64
75
78
}
76
79
77
80
// ShouldResyncFunc is a type of function that indicates if a reflector should perform a
@@ -134,6 +137,7 @@ func (c *controller) Run(stopCh <-chan struct{}) {
134
137
c .config .FullResyncPeriod ,
135
138
)
136
139
r .ShouldResync = c .config .ShouldResync
140
+ r .WatchListPageSize = c .config .WatchListPageSize
137
141
r .clock = c .clock
138
142
if c .config .WatchErrorHandler != nil {
139
143
r .watchErrorHandler = c .config .WatchErrorHandler
You can’t perform that action at this time.
0 commit comments