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