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

Merge pull request #86790 from wojtek-t/dumb_listwatch

Browse Source 
Don't paginate in listwatch
This commit is contained in:
Kubernetes Prow Robot 2020-01-02 19:16:25 -08:00 committed by GitHub
commit 1780792d3c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 6 deletions
Show Stats 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)
} }