From 6f848a98cbe8daa16002e6736e8f6905f03c824d Mon Sep 17 00:00:00 2001 From: deads2k Date: Wed, 28 Jun 2017 16:30:23 -0400 Subject: [PATCH] add reflector metrics Kubernetes-commit: 151d39682e62b288c247d8174a5f7fb139ee7bd1 --- pkg/storage/cacher.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pkg/storage/cacher.go b/pkg/storage/cacher.go index 13f7cf294..9c7839e57 100644 --- a/pkg/storage/cacher.go +++ b/pkg/storage/cacher.go @@ -196,6 +196,7 @@ type Cacher struct { func NewCacherFromConfig(config CacherConfig) *Cacher { watchCache := newWatchCache(config.CacheCapacity, config.KeyFunc, config.GetAttrsFunc) listerWatcher := newCacherListerWatcher(config.Storage, config.ResourcePrefix, config.NewListFunc) + reflectorName := "storage/cacher.go:" + config.ResourcePrefix // Give this error when it is constructed rather than when you get the // first watch item, because it's much easier to track down that way. @@ -212,7 +213,7 @@ func NewCacherFromConfig(config CacherConfig) *Cacher { copier: config.Copier, objectType: reflect.TypeOf(config.Type), watchCache: watchCache, - reflector: cache.NewReflector(listerWatcher, config.Type, watchCache, 0), + reflector: cache.NewNamedReflector(reflectorName, listerWatcher, config.Type, watchCache, 0), versioner: config.Versioner, triggerFunc: config.TriggerPublisherFunc, watcherIdx: 0,