Skip to content

Commit 09a93ab

Browse files
committed
Add NewCluster
Signed-off-by: Nelo-T. Wallus <[email protected]>
1 parent 5457a0f commit 09a93ab

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

third_party/k8s.io/client-go/listers/generic_helpers.go

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,10 @@ func NewCluster[T runtime.Object](indexer cache.Indexer, resource schema.GroupRe
4141
return ResourceClusterIndexer[T]{indexer: indexer, resource: resource}
4242
}
4343

44+
func NewCluster[T runtime.Object](parent ResourceClusterIndexer[T], cluster logicalcluster.Name) ResourceClusterIndexer[T] {
45+
return ResourceClusterIndexer[T]{indexer: parent.indexer, cluster: cluster, resource: parent.resource}
46+
}
47+
4448
// List lists all resources in the indexer matching the given selector.
4549
func (l ResourceClusterIndexer[T]) List(selector labels.Selector) (ret []T, err error) {
4650
err = cache.ListAll(l.indexer, selector, func(m interface{}) {
@@ -60,8 +64,8 @@ type ResourceIndexer[T runtime.Object] struct {
6064

6165
// New returns a new instance of a lister (resource indexer) wrapping the given indexer and resource for the specified type.
6266
// This is intended for use by listers (generated by lister-gen) only.
63-
func New[T runtime.Object](indexer cache.Indexer, cluster logicalcluster.Name, resource schema.GroupResource) ResourceIndexer[T] {
64-
return ResourceIndexer[T]{indexer: indexer, cluster: cluster, resource: resource}
67+
func New[T runtime.Object](indexer cache.Indexer, resource schema.GroupResource) ResourceIndexer[T] {
68+
return ResourceIndexer[T]{indexer: indexer, cluster: logicalcluster.Name(""), resource: resource}
6569
}
6670

6771
// NewNamespaced returns a new instance of a namespaced lister (resource indexer) wrapping the given parent and namespace for the specified type.

0 commit comments

Comments
 (0)