Merge pull request #327 from openconfig/fix326

initialize event-combine processor with the full list of processors
openconfig · Dec 23, 2023 · 3f8a9ba · 3f8a9ba
2 parents 2027acb + bec4882
commit 3f8a9ba
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 3 deletions.
diff --git a/go.mod b/go.mod
@@ -21,6 +21,7 @@ require (
 	github.com/guptarohit/asciigraph v0.5.6
 	github.com/hairyhenderson/gomplate/v3 v3.11.5
 	github.com/hashicorp/consul/api v1.25.1
+	github.com/hashicorp/go-plugin v1.4.9
 	github.com/hashicorp/golang-lru/v2 v2.0.7
 	github.com/huandu/xstrings v1.4.0
 	github.com/influxdata/influxdb-client-go/v2 v2.12.3
@@ -104,7 +105,6 @@ require (
 	github.com/grafana/regexp v0.0.0-20221122212121-6b5c0a4cb7fd // indirect
 	github.com/hairyhenderson/go-fsimpl v0.0.0-20220529183339-9deae3e35047 // indirect
 	github.com/hairyhenderson/yaml v0.0.0-20220618171115-2d35fca545ce // indirect
-	github.com/hashicorp/go-plugin v1.4.9 // indirect
 	github.com/hashicorp/go-secure-stdlib/mlock v0.1.2 // indirect
 	github.com/hashicorp/go-secure-stdlib/parseutil v0.1.7 // indirect
 	github.com/hashicorp/go-secure-stdlib/strutil v0.1.2 // indirect
@@ -200,7 +200,7 @@ require (
 	github.com/hairyhenderson/toml v0.4.2-0.20210923231440-40456b8e66cf // indirect
 	github.com/hashicorp/errwrap v1.1.0 // indirect
 	github.com/hashicorp/go-cleanhttp v0.5.2 // indirect
-	github.com/hashicorp/go-hclog v1.5.0 // indirect
+	github.com/hashicorp/go-hclog v1.5.0
 	github.com/hashicorp/go-immutable-radix v1.3.1 // indirect
 	github.com/hashicorp/go-multierror v1.1.1 // indirect
 	github.com/hashicorp/go-retryablehttp v0.7.2 // indirect

diff --git a/pkg/formatters/event_combine/event_combine.go b/pkg/formatters/event_combine/event_combine.go
@@ -100,7 +100,7 @@ func (p *combine) Init(cfg any, opts ...formatters.Option) error {
 					formatters.WithLogger(p.logger),
 					formatters.WithTargets(p.targetsConfigs),
 					formatters.WithActions(p.actionsDefinitions),
-					formatters.WithProcessors(p.actionsDefinitions),
+					formatters.WithProcessors(p.processorsDefinitions),
 				)
 				if err != nil {
 					return fmt.Errorf("failed initializing event processor '%s' of type='%s': %v", proc.Name, epType, err)

diff --git a/pkg/formatters/processors.go b/pkg/formatters/processors.go
@@ -158,6 +158,7 @@ func MakeEventProcessors(
 					WithLogger(logger),
 					WithTargets(tcs),
 					WithActions(acts),
+					WithProcessors(ps),
 				)
 				if err != nil {
 					return nil, fmt.Errorf("failed initializing event processor '%s' of type='%s': %w", epName, epType, err)