From 206a3638d294df355e110e262670c3b7d930ec3c Mon Sep 17 00:00:00 2001 From: Karolis Rusenas Date: Sun, 2 Jul 2017 20:09:54 +0100 Subject: [PATCH] initialising poll manager --- main.go | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/main.go b/main.go index 11c6bcc5..a6141589 100644 --- a/main.go +++ b/main.go @@ -9,7 +9,9 @@ import ( "github.com/rusenask/keel/provider" "github.com/rusenask/keel/provider/kubernetes" + "github.com/rusenask/keel/registry" "github.com/rusenask/keel/trigger/http" + "github.com/rusenask/keel/trigger/poll" "github.com/rusenask/keel/trigger/pubsub" "github.com/rusenask/keel/types" "github.com/rusenask/keel/version" @@ -20,6 +22,7 @@ import ( // gcloud pubsub related config const ( EnvTriggerPubSub = "PUBSUB" // set to 1 or something to enable pub/sub trigger + EnvTriggerPoll = "POLL" // set to 1 or something to enable poll trigger EnvProjectID = "PROJECT_ID" ) @@ -154,6 +157,16 @@ func setupTriggers(ctx context.Context, k8sImplementer kubernetes.Implementer, p go subManager.Start(ctx) } + if os.Getenv(EnvTriggerPoll) != "" { + + registryClient := registry.New() + watcher := poll.NewRepositoryWatcher(providers, registryClient) + pollManager := poll.NewPollManager(k8sImplementer, watcher) + + // start poll manager, will finish with ctx + go pollManager.Start(ctx) + } + teardown = func() { whs.Stop() }