From 82e60f7c7280ff3d5077cfd871d6feeb42fea060 Mon Sep 17 00:00:00 2001 From: sun Date: Thu, 19 Apr 2018 01:46:46 +0800 Subject: [PATCH] fix secret (#132) --- manager/resource.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/manager/resource.go b/manager/resource.go index cd12a14ad..2162e0ae2 100644 --- a/manager/resource.go +++ b/manager/resource.go @@ -44,7 +44,7 @@ func NewResourceManager(k8sClient kubernetes.Interface) *ResourceManager { rm.Lock() for n, c := range rm.secretRef { if c <= 0 { - delete(rm.secrets, n) + delete(rm.secretRef, n) } } for n := range rm.secrets { @@ -54,7 +54,7 @@ func NewResourceManager(k8sClient kubernetes.Interface) *ResourceManager { } for n, c := range rm.configMapRef { if c <= 0 { - delete(rm.configMaps, n) + delete(rm.configMapRef, n) } } for n := range rm.configMaps { @@ -230,7 +230,7 @@ func (rm *ResourceManager) watchConfigMaps() { // it evicts them from the internal cache func (rm *ResourceManager) watchSecrets() { var opts metav1.ListOptions - w, err := rm.k8sClient.CoreV1().ConfigMaps(v1.NamespaceAll).Watch(opts) + w, err := rm.k8sClient.CoreV1().Secrets(v1.NamespaceAll).Watch(opts) if err != nil { log.Fatal(err) } @@ -245,9 +245,9 @@ func (rm *ResourceManager) watchSecrets() { rm.Lock() switch ev.Type { case watch.Modified: - delete(rm.configMaps, ev.Object.(*v1.ConfigMap).Name) + delete(rm.secrets, ev.Object.(*v1.Secret).Name) case watch.Deleted: - delete(rm.configMaps, ev.Object.(*v1.ConfigMap).Name) + delete(rm.secrets, ev.Object.(*v1.Secret).Name) } rm.Unlock() }