...
1
16
17
18
19 package v1
20
21 import (
22 v1 "k8s.io/api/apps/v1"
23 "k8s.io/apimachinery/pkg/api/errors"
24 "k8s.io/apimachinery/pkg/labels"
25 "k8s.io/client-go/tools/cache"
26 )
27
28
29
30 type ReplicaSetLister interface {
31
32
33 List(selector labels.Selector) (ret []*v1.ReplicaSet, err error)
34
35 ReplicaSets(namespace string) ReplicaSetNamespaceLister
36 ReplicaSetListerExpansion
37 }
38
39
40 type replicaSetLister struct {
41 indexer cache.Indexer
42 }
43
44
45 func NewReplicaSetLister(indexer cache.Indexer) ReplicaSetLister {
46 return &replicaSetLister{indexer: indexer}
47 }
48
49
50 func (s *replicaSetLister) List(selector labels.Selector) (ret []*v1.ReplicaSet, err error) {
51 err = cache.ListAll(s.indexer, selector, func(m interface{}) {
52 ret = append(ret, m.(*v1.ReplicaSet))
53 })
54 return ret, err
55 }
56
57
58 func (s *replicaSetLister) ReplicaSets(namespace string) ReplicaSetNamespaceLister {
59 return replicaSetNamespaceLister{indexer: s.indexer, namespace: namespace}
60 }
61
62
63
64 type ReplicaSetNamespaceLister interface {
65
66
67 List(selector labels.Selector) (ret []*v1.ReplicaSet, err error)
68
69
70 Get(name string) (*v1.ReplicaSet, error)
71 ReplicaSetNamespaceListerExpansion
72 }
73
74
75
76 type replicaSetNamespaceLister struct {
77 indexer cache.Indexer
78 namespace string
79 }
80
81
82 func (s replicaSetNamespaceLister) List(selector labels.Selector) (ret []*v1.ReplicaSet, err error) {
83 err = cache.ListAllByNamespace(s.indexer, s.namespace, selector, func(m interface{}) {
84 ret = append(ret, m.(*v1.ReplicaSet))
85 })
86 return ret, err
87 }
88
89
90 func (s replicaSetNamespaceLister) Get(name string) (*v1.ReplicaSet, error) {
91 obj, exists, err := s.indexer.GetByKey(s.namespace + "/" + name)
92 if err != nil {
93 return nil, err
94 }
95 if !exists {
96 return nil, errors.NewNotFound(v1.Resource("replicaset"), name)
97 }
98 return obj.(*v1.ReplicaSet), nil
99 }
100
View as plain text