update getOutputs function
@@ -61,7 +61,7 @@ var subscribeCmd = &cobra.Command{
if debug {
logger.Printf("subscriptions: %s", subscriptionsConfig)
}
- outs, err := getOutputs()
+ outs, err := getOutputs(ctx)
if err != nil {
return err
}
@@ -210,7 +210,7 @@ func init() {
viper.BindPFlag("subscribe-name", subscribeCmd.LocalFlags().Lookup("name"))
}
-func getOutputs() (map[string][]outputs.Output, error) {
+func getOutputs(ctx context.Context) (map[string][]outputs.Output, error) {
outDef := viper.GetStringMap("outputs")
if len(outDef) == 0 && !viper.GetBool("quiet") {
stdoutConfig := map[string]interface{}{
@@ -235,7 +235,7 @@ func getOutputs() (map[string][]outputs.Output, error) {
ou["format"] = viper.GetString("format")
}
o := initalizer()
- err := o.Init(ou, logger)
+ err := o.Init(ctx, ou, logger)
if err != nil {
return nil, err
}
