github/Reloader
1
0
Fork 0
mirror of https://github.com/stakater/Reloader.git synced 2026-05-03 07:16:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

Added logs on startup & get ns opration

Browse Source
This commit is contained in:
avihuly
2023-01-05 12:54:08 +02:00
parent 9263b812eb
commit 8ebbb476b2
2 changed files with 16 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
internal/pkg/cmd/reloader.go
View File

@@ -138,6 +138,10 @@ func startReloader(cmd *cobra.Command, args []string) {
logrus.Fatal(err)
}
if len(namespaceLabelSelector) > 0 {
logrus.Warnf("namespace-selector is set, will detect changes in namespaces with these labels: %s.", namespaceLabelSelector)
}
collectors := metrics.SetupPrometheusEndpoint()
var controllers []*controller.Controller

14
internal/pkg/controller/controller.go
View File

@@ -104,7 +104,12 @@ func (c *Controller) resourceInNamespaceSelector(raw interface{}) bool {
switch object := raw.(type) {
case *v1.ConfigMap:
namespace, _ := c.client.CoreV1().Namespaces().Get(context.Background(), object.ObjectMeta.Namespace, metav1.GetOptions{})
namespace, err := c.client.CoreV1().Namespaces().Get(context.Background(), object.ObjectMeta.Namespace, metav1.GetOptions{})
if err != nil {
logrus.Warn(err)
return false
}
for selectorKey, selectorVal := range c.namespaceSelector {
namespaceLabelVal, namespaceLabelKeyExists := namespace.ObjectMeta.Labels[selectorKey]
if !namespaceLabelKeyExists || selectorVal != namespaceLabelVal {
@@ -112,7 +117,12 @@ func (c *Controller) resourceInNamespaceSelector(raw interface{}) bool {
}
}
case *v1.Secret:
namespace, _ := c.client.CoreV1().Namespaces().Get(context.Background(), object.ObjectMeta.Namespace, metav1.GetOptions{})
namespace, err := c.client.CoreV1().Namespaces().Get(context.Background(), object.ObjectMeta.Namespace, metav1.GetOptions{})
if err != nil {
logrus.Warn(err)
return false
}
for selectorKey, selectorVal := range c.namespaceSelector {
namespaceLabelVal, namespaceLabelKeyExists := namespace.ObjectMeta.Labels[selectorKey]
if !namespaceLabelKeyExists || selectorVal != namespaceLabelVal {