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

provider manager

pull/13/head
Karolis Rusenas 2017-07-01 14:39:03 +01:00
parent a3eebe217f
commit f9ec54c8ad
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
main.go
View File

@ -101,7 +101,7 @@ func main() {
// setupProviders - setting up available providers. New providers should be initialised here and added to
// provider map
func setupProviders(k8sImplementer kubernetes.Implementer) (providers map[string]provider.Provider, teardown func()) {
func setupProviders(k8sImplementer kubernetes.Implementer) (providers provider.Providers, teardown func()) {
k8sProvider, err := kubernetes.NewProvider(k8sImplementer)
if err != nil {
log.WithFields(log.Fields{
@ -110,8 +110,7 @@ func setupProviders(k8sImplementer kubernetes.Implementer) (providers map[string
}
go k8sProvider.Start()
providers = make(map[string]provider.Provider)
providers[k8sProvider.GetName()] = k8sProvider
providers = provider.New([]provider.Provider{k8sProvider})
teardown = func() {
k8sProvider.Stop()
@ -122,7 +121,7 @@ func setupProviders(k8sImplementer kubernetes.Implementer) (providers map[string
// 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, k8sImplementer kubernetes.Implementer, providers map[string]provider.Provider) (teardown func()) {
func setupTriggers(ctx context.Context, k8sImplementer kubernetes.Implementer, providers provider.Providers) (teardown func()) {
// setting up generic http webhook server
whs := http.NewTriggerServer(&http.Opts{