...
1
16
17
18
19 package v2beta1
20
21 import (
22 v2beta1 "k8s.io/api/autoscaling/v2beta1"
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 HorizontalPodAutoscalerLister interface {
31
32
33 List(selector labels.Selector) (ret []*v2beta1.HorizontalPodAutoscaler, err error)
34
35 HorizontalPodAutoscalers(namespace string) HorizontalPodAutoscalerNamespaceLister
36 HorizontalPodAutoscalerListerExpansion
37 }
38
39
40 type horizontalPodAutoscalerLister struct {
41 indexer cache.Indexer
42 }
43
44
45 func NewHorizontalPodAutoscalerLister(indexer cache.Indexer) HorizontalPodAutoscalerLister {
46 return &horizontalPodAutoscalerLister{indexer: indexer}
47 }
48
49
50 func (s *horizontalPodAutoscalerLister) List(selector labels.Selector) (ret []*v2beta1.HorizontalPodAutoscaler, err error) {
51 err = cache.ListAll(s.indexer, selector, func(m interface{}) {
52 ret = append(ret, m.(*v2beta1.HorizontalPodAutoscaler))
53 })
54 return ret, err
55 }
56
57
58 func (s *horizontalPodAutoscalerLister) HorizontalPodAutoscalers(namespace string) HorizontalPodAutoscalerNamespaceLister {
59 return horizontalPodAutoscalerNamespaceLister{indexer: s.indexer, namespace: namespace}
60 }
61
62
63
64 type HorizontalPodAutoscalerNamespaceLister interface {
65
66
67 List(selector labels.Selector) (ret []*v2beta1.HorizontalPodAutoscaler, err error)
68
69
70 Get(name string) (*v2beta1.HorizontalPodAutoscaler, error)
71 HorizontalPodAutoscalerNamespaceListerExpansion
72 }
73
74
75
76 type horizontalPodAutoscalerNamespaceLister struct {
77 indexer cache.Indexer
78 namespace string
79 }
80
81
82 func (s horizontalPodAutoscalerNamespaceLister) List(selector labels.Selector) (ret []*v2beta1.HorizontalPodAutoscaler, err error) {
83 err = cache.ListAllByNamespace(s.indexer, s.namespace, selector, func(m interface{}) {
84 ret = append(ret, m.(*v2beta1.HorizontalPodAutoscaler))
85 })
86 return ret, err
87 }
88
89
90 func (s horizontalPodAutoscalerNamespaceLister) Get(name string) (*v2beta1.HorizontalPodAutoscaler, 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(v2beta1.Resource("horizontalpodautoscaler"), name)
97 }
98 return obj.(*v2beta1.HorizontalPodAutoscaler), nil
99 }
100
View as plain text