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

Convert StoreToLimitRangeLister to LimitRangeLister

Browse Source
This commit is contained in:
Andy Goldstein 2016-10-26 12:14:06 -04:00
parent 7b85985a72
commit 5ab385480b
2 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
pkg/controller/informers/core.go
View File

@ -23,6 +23,7 @@ import (
"k8s.io/kubernetes/pkg/api" "k8s.io/kubernetes/pkg/api"
"k8s.io/kubernetes/pkg/client/cache" "k8s.io/kubernetes/pkg/client/cache"
clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset" clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset"
coreinternallisters "k8s.io/kubernetes/pkg/client/listers/core/internalversion"
"k8s.io/kubernetes/pkg/runtime" "k8s.io/kubernetes/pkg/runtime"
"k8s.io/kubernetes/pkg/watch" "k8s.io/kubernetes/pkg/watch"
) )
@ -211,7 +212,7 @@ func (f *pvInformer) Lister() *cache.StoreToPVFetcher {
// Interface provides constructor for informer and lister for limit ranges. // Interface provides constructor for informer and lister for limit ranges.
type LimitRangeInformer interface { type LimitRangeInformer interface {
Informer() cache.SharedIndexInformer Informer() cache.SharedIndexInformer
Lister() *cache.StoreToLimitRangeLister Lister() coreinternallisters.LimitRangeLister
} }
type limitRangeInformer struct { type limitRangeInformer struct {
@ -236,9 +237,9 @@ func (f *limitRangeInformer) Informer() cache.SharedIndexInformer {
} }
// Lister returns lister for limitRangeInformer // Lister returns lister for limitRangeInformer
func (f *limitRangeInformer) Lister() *cache.StoreToLimitRangeLister { func (f *limitRangeInformer) Lister() coreinternallisters.LimitRangeLister {
informer := f.Informer() informer := f.Informer()
return &cache.StoreToLimitRangeLister{Indexer: informer.GetIndexer()} return coreinternallisters.NewLimitRangeLister(informer.GetIndexer())
} }
// NewPodInformer returns a SharedIndexInformer that lists and watches all pods // NewPodInformer returns a SharedIndexInformer that lists and watches all pods

4
plugin/pkg/admission/limitranger/admission.go
View File

@ -26,13 +26,13 @@ import (
lru "github.com/hashicorp/golang-lru" lru "github.com/hashicorp/golang-lru"
clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset" clientset "k8s.io/kubernetes/pkg/client/clientset_generated/internalclientset"
coreinternallisters "k8s.io/kubernetes/pkg/client/listers/core/internalversion"
"k8s.io/kubernetes/pkg/controller/informers" "k8s.io/kubernetes/pkg/controller/informers"
"k8s.io/kubernetes/pkg/admission" "k8s.io/kubernetes/pkg/admission"
"k8s.io/kubernetes/pkg/api" "k8s.io/kubernetes/pkg/api"
"k8s.io/kubernetes/pkg/api/meta" "k8s.io/kubernetes/pkg/api/meta"
"k8s.io/kubernetes/pkg/api/resource" "k8s.io/kubernetes/pkg/api/resource"
"k8s.io/kubernetes/pkg/client/cache"
"k8s.io/kubernetes/pkg/labels" "k8s.io/kubernetes/pkg/labels"
"k8s.io/kubernetes/pkg/runtime" "k8s.io/kubernetes/pkg/runtime"
utilerrors "k8s.io/kubernetes/pkg/util/errors" utilerrors "k8s.io/kubernetes/pkg/util/errors"
@ -53,7 +53,7 @@ type limitRanger struct {
*admission.Handler *admission.Handler
client clientset.Interface client clientset.Interface
actions LimitRangerActions actions LimitRangerActions
lister *cache.StoreToLimitRangeLister lister coreinternallisters.LimitRangeLister
// liveLookups holds the last few live lookups we've done to help ammortize cost on repeated lookup failures. // liveLookups holds the last few live lookups we've done to help ammortize cost on repeated lookup failures.
// This let's us handle the case of latent caches, by looking up actual results for a namespace on cache miss/no results. // This let's us handle the case of latent caches, by looking up actual results for a namespace on cache miss/no results.