File tree Expand file tree Collapse file tree 2 files changed +17
-8
lines changed Expand file tree Collapse file tree 2 files changed +17
-8
lines changed Original file line number Diff line number Diff line change 1- // Copyright 2023 Blink Labs Software
1+ // Copyright 2025 Blink Labs Software
22//
33// Licensed under the Apache License, Version 2.0 (the "License");
44// you may not use this file except in compliance with the License.
@@ -31,14 +31,14 @@ const (
3131
3232type Config struct {
3333 Api ApiConfig `yaml:"api"`
34- ConfigFile string `yaml:"-"`
35- Version bool `yaml:"-"`
3634 Logging LoggingConfig `yaml:"logging"`
3735 Debug DebugConfig `yaml:"debug"`
38- Input string `yaml:"input" envconfig:"INPUT"`
39- Output string `yaml:"output" envconfig:"OUTPUT"`
4036 Plugin map [string ]map [string ]map [any ]any `yaml:"plugins"`
37+ ConfigFile string `yaml:"-"`
38+ Input string `yaml:"input" envconfig:"INPUT"`
39+ Output string `yaml:"output" envconfig:"OUTPUT"`
4140 KupoUrl string `yaml:"kupo_url" envconfig:"KUPO_URL"`
41+ Version bool `yaml:"-"`
4242}
4343
4444type ApiConfig struct {
Original file line number Diff line number Diff line change @@ -141,17 +141,26 @@ func (p *Pipeline) Stop() error {
141141 // Stop plugins and collect errors
142142 for _ , input := range p .inputs {
143143 if err := input .Stop (); err != nil {
144- stopErrors = append (stopErrors , fmt .Errorf ("failed to stop input: %w" , err ))
144+ stopErrors = append (
145+ stopErrors ,
146+ fmt .Errorf ("failed to stop input: %w" , err ),
147+ )
145148 }
146149 }
147150 for _ , filter := range p .filters {
148151 if err := filter .Stop (); err != nil {
149- stopErrors = append (stopErrors , fmt .Errorf ("failed to stop filter: %w" , err ))
152+ stopErrors = append (
153+ stopErrors ,
154+ fmt .Errorf ("failed to stop filter: %w" , err ),
155+ )
150156 }
151157 }
152158 for _ , output := range p .outputs {
153159 if err := output .Stop (); err != nil {
154- stopErrors = append (stopErrors , fmt .Errorf ("failed to stop output: %w" , err ))
160+ stopErrors = append (
161+ stopErrors ,
162+ fmt .Errorf ("failed to stop output: %w" , err ),
163+ )
155164 }
156165 }
157166
You can’t perform that action at this time.
0 commit comments