cmd/stepd: Initialize initializers
This commit is contained in:
parent
32fd1ebfd6
commit
9e3955f92f
@ -186,6 +186,16 @@ func main () {
|
|||||||
environment.Providers = append(environment.Providers, plugins...)
|
environment.Providers = append(environment.Providers, plugins...)
|
||||||
logProviders(environment.Providers)
|
logProviders(environment.Providers)
|
||||||
|
|
||||||
|
// initialize providers
|
||||||
|
for _, provider := range environment.Providers {
|
||||||
|
if initializer, ok := provider.(step.Initializer); ok {
|
||||||
|
err := initializer.Init()
|
||||||
|
if err != nil {
|
||||||
|
log.Fatalln("XXX initializing %s: %v", provider.Package(), err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
// initialize the environment
|
// initialize the environment
|
||||||
err = environment.Init(context.Background())
|
err = environment.Init(context.Background())
|
||||||
if err != nil { log.Fatal("XXX:", err) }
|
if err != nil { log.Fatal("XXX:", err) }
|
||||||
@ -229,6 +239,11 @@ func main () {
|
|||||||
&handler,
|
&handler,
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
for _, provider := range environment.Providers {
|
||||||
|
if provider, ok := provider.(step.Trimmer); ok {
|
||||||
|
trimmer.Trimmers = append(trimmer.Trimmers, provider)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
// set up the routine manager
|
// set up the routine manager
|
||||||
manager := routines.Manager {
|
manager := routines.Manager {
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user