Fix error reporting - use the enum graphql type (#232)

otterize · Aug 6, 2024 · 2d8d658 · 2d8d658
1 parent 7969e19
commit 2d8d658
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 3 deletions.
diff --git a/src/kafka-watcher/cmd/main.go b/src/kafka-watcher/cmd/main.go
@@ -11,6 +11,7 @@ import (
 	"github.com/otterize/intents-operator/src/shared/errors"
 	"github.com/otterize/intents-operator/src/shared/telemetries/componentinfo"
 	"github.com/otterize/intents-operator/src/shared/telemetries/errorreporter"
+	"github.com/otterize/intents-operator/src/shared/telemetries/telemetriesgql"
 	"github.com/otterize/intents-operator/src/shared/telemetries/telemetrysender"
 	"github.com/otterize/network-mapper/src/kafka-watcher/pkg/config"
 	logwatcher2 "github.com/otterize/network-mapper/src/kafka-watcher/pkg/logwatcher"
@@ -39,7 +40,7 @@ func main() {
 	errgrp, errGroupCtx := errgroup.WithContext(signals.SetupSignalHandler())
 	clusterUID := clusterutils.GetOrCreateClusterUID(errGroupCtx)
 	componentinfo.SetGlobalContextId(telemetrysender.Anonymize(clusterUID))
-	errorreporter.Init("kafka-watcher", version.Version())
+	errorreporter.Init(telemetriesgql.TelemetryComponentTypeNetworkMapper, version.Version())
 	defer errorreporter.AutoNotify()
 	shared.RegisterPanicHandlers()
 

diff --git a/src/mapper/cmd/main.go b/src/mapper/cmd/main.go
@@ -98,7 +98,7 @@ func main() {
 
 	componentinfo.SetGlobalContextId(telemetrysender.Anonymize(clusterUID))
 
-	errorreporter.Init("network-mapper", version.Version())
+	errorreporter.Init(telemetriesgql.TelemetryComponentTypeNetworkMapper, version.Version())
 	defer errorreporter.AutoNotify()
 	shared.RegisterPanicHandlers()
 

diff --git a/src/sniffer/cmd/main.go b/src/sniffer/cmd/main.go
@@ -10,6 +10,7 @@ import (
 	"github.com/otterize/intents-operator/src/shared/errors"
 	"github.com/otterize/intents-operator/src/shared/telemetries/componentinfo"
 	"github.com/otterize/intents-operator/src/shared/telemetries/errorreporter"
+	"github.com/otterize/intents-operator/src/shared/telemetries/telemetriesgql"
 	"github.com/otterize/intents-operator/src/shared/telemetries/telemetrysender"
 	"github.com/otterize/network-mapper/src/shared/version"
 	"golang.org/x/sync/errgroup"
@@ -37,7 +38,7 @@ func main() {
 	errgrp, errGroupCtx := errgroup.WithContext(signals.SetupSignalHandler())
 	clusterUID := clusterutils.GetOrCreateClusterUID(errGroupCtx)
 	componentinfo.SetGlobalContextId(telemetrysender.Anonymize(clusterUID))
-	errorreporter.Init("sniffer", version.Version())
+	errorreporter.Init(telemetriesgql.TelemetryComponentTypeNetworkMapper, version.Version())
 	defer errorreporter.AutoNotify()
 	shared.RegisterPanicHandlers()