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

preparing secrets getter

pull/65/head
Karolis Rusenas 2017-07-28 23:20:24 +01:00
parent 556294e87f
commit 61cc0e2c11
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
main.go
View File

@ -16,6 +16,7 @@ import (
"github.com/rusenask/keel/provider/helm"
"github.com/rusenask/keel/provider/kubernetes"
"github.com/rusenask/keel/registry"
"github.com/rusenask/keel/secrets"
"github.com/rusenask/keel/trigger/http"
"github.com/rusenask/keel/trigger/poll"
"github.com/rusenask/keel/trigger/pubsub"
@ -97,7 +98,9 @@ func main() {
// setting up providers
providers := setupProviders(implementer, sender)
teardownTriggers := setupTriggers(ctx, providers)
secretsGetter := secrets.NewGetter(implementer)
teardownTriggers := setupTriggers(ctx, providers, secretsGetter)
teardownBot, err := setupBot(implementer)
if err != nil {
@ -197,7 +200,7 @@ func setupBot(k8sImplementer kubernetes.Implementer) (teardown func(), err error
// setupTriggers - setting up triggers. New triggers should be added to this function. Each trigger
// should go through all providers (or not if there is a reason) and submit events)
func setupTriggers(ctx context.Context, providers provider.Providers) (teardown func()) {
func setupTriggers(ctx context.Context, providers provider.Providers, secretsGetter secrets.Getter) (teardown func()) {
// setting up generic http webhook server
whs := http.NewTriggerServer(&http.Opts{
@ -234,7 +237,7 @@ func setupTriggers(ctx context.Context, providers provider.Providers) (teardown
registryClient := registry.New()
watcher := poll.NewRepositoryWatcher(providers, registryClient)
pollManager := poll.NewPollManager(providers, watcher)
pollManager := poll.NewPollManager(providers, watcher, secretsGetter)
// start poll manager, will finish with ctx
go watcher.Start(ctx)