Merge pull request #44 from rusenask/develop

Develop

hack/deployment.sample.yml

@@ -20,8 +20,8 @@ spec:
         - image: karolisr/keel:0.3.1
           imagePullPolicy: Always
           env:          
-            - name: POLL
-              value: "1"               
+            # - name: POLL
+            #   value: "1"               
             - name: PUBSUB
               value: "1"
             # Enable/disable Helm provider  

main.go

@@ -57,7 +57,7 @@ func main() {
 		"version":    ver.Version,
 		"go_version": ver.GoVersion,
 		"arch":       ver.Arch,
-	}).Info("Keel starting..")
+	}).Info("keel starting..")
 
 	if os.Getenv(EnvDebug) != "" {
 		log.SetLevel(log.DebugLevel)
@@ -230,7 +230,7 @@ func setupTriggers(ctx context.Context, providers provider.Providers) (teardown
 		go subManager.Start(ctx)
 	}
 
-	if os.Getenv(EnvTriggerPoll) != "" {
+	if os.Getenv(EnvTriggerPoll) != "0" {
 
 		registryClient := registry.New()
 		watcher := poll.NewRepositoryWatcher(providers, registryClient)

provider/provider.go

@@ -28,7 +28,7 @@ func New(providers []Provider) *DefaultProviders {
 
 	for _, p := range providers {
 		pvs[p.GetName()] = p
-		log.Infof("provider.DefaultProviders: provider '%s' registered", p.GetName())
+		log.Infof("provider.defaultProviders: provider '%s' registered", p.GetName())
 	}
 
 	return &DefaultProviders{
@@ -51,7 +51,7 @@ func (p *DefaultProviders) Submit(event types.Event) error {
 				"provider": provider.GetName(),
 				"event":    event.Repository,
 				"trigger":  event.TriggerName,
-			}).Error("provider.DefaultProviders: submit event failed")
+			}).Error("provider.defaultProviders: submit event failed")
 		}
 	}
 
@@ -67,7 +67,7 @@ func (p *DefaultProviders) TrackedImages() ([]*types.TrackedImage, error) {
 			log.WithFields(log.Fields{
 				"error":    err,
 				"provider": provider.GetName(),
-			}).Error("provider.DefaultProviders: failed to get tracked images")
+			}).Error("provider.defaultProviders: failed to get tracked images")
 			continue
 		}
 		trackedImages = append(trackedImages, ti...)

trigger/poll/manager.go

@@ -51,6 +51,8 @@ func (s *DefaultManager) Start(ctx context.Context) error {
 	// setting root context
 	s.ctx = ctx
 
+	log.Info("trigger.poll.manager: polling trigger configured")
+
 	// initial scan
 	err := s.scan(ctx)
 	if err != nil {