keel-hq
/
keel
mirror of https://github.com/keel-hq/keel/tree/master/chart/keel
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Update watcher.go

pull/614/head
NicolasLemince 2021-06-14 14:15:53 +02:00 committed by GitHub
parent 548693276a
commit 75be0aba81
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
internal/k8s/watcher.go
View File

@ -42,16 +42,16 @@ func watch(g *workgroup.Group, c cache.Getter, log logrus.FieldLogger, resource
//Check if the env var RESTRICTED_NAMESPACE is empty or equal to keel
// If equal to keel or empty, the scan will be over all the cluster
// If RESTRICTED_NAMESPACE is different than keel or empty, keel will scan in the defined namespace
namespace_scan := "keel"
namespaceScan := "keel"
if os.Getenv(constants.EnvRestrictedNamespace) == "keel" {
namespace_scan = v1.NamespaceAll
namespaceScan = v1.NamespaceAll
} else if os.Getenv(constants.EnvRestrictedNamespace) == "" {
namespace_scan = v1.NamespaceAll
namespaceScan = v1.NamespaceAll
} else {
namespace_scan = os.Getenv(constants.EnvRestrictedNamespace)
namespaceScan = os.Getenv(constants.EnvRestrictedNamespace)
}
lw := cache.NewListWatchFromClient(c, resource, namespace_scan, fields.Everything())
lw := cache.NewListWatchFromClient(c, resource, namespaceScan, fields.Everything())
sw := cache.NewSharedInformer(lw, objType, 30*time.Minute)
for _, r := range rs {
sw.AddEventHandler(r)