Add resourceVersion=0 paginated list integration test for disabled and enabled watch cache

Kubernetes-commit: e5a4f09ab3ac15815ceb039fbc7f546266855fd6
This commit is contained in:
Joe Betz 2019-03-21 11:25:07 -07:00 committed by Kubernetes Publisher
parent d858f18787
commit d43f2ef228

View File

@ -192,6 +192,7 @@ func (r *Reflector) ListAndWatch(stopCh <-chan struct{}) error {
if r.WatchListPageSize != 0 {
pager.PageSize = r.WatchListPageSize
}
// Pager falls back to full list if paginated list calls fail due to an "Expired" error.
list, err = pager.List(context.Background(), options)
close(listCh)
}()