github/kubernetes
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Don't paginate in listwatch

Browse Source
This commit is contained in:
wojtekt
2020-01-02 20:09:19 +01:00
parent f7e9a7c194
commit 51eb4b50a3
1 changed files with 2 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
staging/src/k8s.io/client-go/tools/cache/listwatch.go vendored
View File

@@ -17,14 +17,11 @@ limitations under the License.
package cache package cache
import ( import (
"context"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/fields" "k8s.io/apimachinery/pkg/fields"
"k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/runtime"
"k8s.io/apimachinery/pkg/watch" "k8s.io/apimachinery/pkg/watch"
restclient "k8s.io/client-go/rest" restclient "k8s.io/client-go/rest"
"k8s.io/client-go/tools/pager"
) )
// Lister is any object that knows how to perform an initial list. // Lister is any object that knows how to perform an initial list.
@@ -102,9 +99,8 @@ func NewFilteredListWatchFromClient(c Getter, resource string, namespace string,
// List a set of apiserver resources // List a set of apiserver resources
func (lw *ListWatch) List(options metav1.ListOptions) (runtime.Object, error) { func (lw *ListWatch) List(options metav1.ListOptions) (runtime.Object, error) {
if !lw.DisableChunking { // ListWatch is used in Reflector, which already supports pagination.
return pager.New(pager.SimplePageFunc(lw.ListFunc)).List(context.TODO(), options) // Don't paginate here to avoid duplication.
}
return lw.ListFunc(options) return lw.ListFunc(options)
} }