d8dfun/virtual-kubelet
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

fix secret (#132)

Browse Source
This commit is contained in:
sun
2018-04-19 01:46:46 +08:00
committed by Robbie Zhang
parent 28c02d882a
commit 82e60f7c72
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
manager/resource.go
View File

@@ -44,7 +44,7 @@ func NewResourceManager(k8sClient kubernetes.Interface) *ResourceManager {
rm.Lock() rm.Lock()
for n, c := range rm.secretRef { for n, c := range rm.secretRef {
if c <= 0 { if c <= 0 {
delete(rm.secrets, n) delete(rm.secretRef, n)
} }
} }
for n := range rm.secrets { for n := range rm.secrets {
@@ -54,7 +54,7 @@ func NewResourceManager(k8sClient kubernetes.Interface) *ResourceManager {
} }
for n, c := range rm.configMapRef { for n, c := range rm.configMapRef {
if c <= 0 { if c <= 0 {
delete(rm.configMaps, n) delete(rm.configMapRef, n)
} }
} }
for n := range rm.configMaps { for n := range rm.configMaps {
@@ -230,7 +230,7 @@ func (rm *ResourceManager) watchConfigMaps() {
// it evicts them from the internal cache // it evicts them from the internal cache
func (rm *ResourceManager) watchSecrets() { func (rm *ResourceManager) watchSecrets() {
var opts metav1.ListOptions 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 { if err != nil {
log.Fatal(err) log.Fatal(err)
} }
@@ -245,9 +245,9 @@ func (rm *ResourceManager) watchSecrets() {
rm.Lock() rm.Lock()
switch ev.Type { switch ev.Type {
case watch.Modified: case watch.Modified:
delete(rm.configMaps, ev.Object.(*v1.ConfigMap).Name) delete(rm.secrets, ev.Object.(*v1.Secret).Name)
case watch.Deleted: case watch.Deleted:
delete(rm.configMaps, ev.Object.(*v1.ConfigMap).Name) delete(rm.secrets, ev.Object.(*v1.Secret).Name)
} }
rm.Unlock() rm.Unlock()
} }