go cluster-metadata-service: Fix broker dependency injection

Magpie-Monitor · Dec 15, 2024 · 75ba31e · 75ba31e
1 parent 2e37164
commit 75ba31e
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/go/services/cluster_metadata/pkg/services/event_service.go b/go/services/cluster_metadata/pkg/services/event_service.go
@@ -1,13 +1,12 @@
 package services
 
 import (
-	"os"
-
 	"github.com/Magpie-Monitor/magpie-monitor/pkg/envs"
 	messagebroker "github.com/Magpie-Monitor/magpie-monitor/pkg/message-broker"
 	"github.com/Magpie-Monitor/magpie-monitor/services/cluster_metadata/pkg/repositories"
 	"github.com/google/uuid"
 	"go.uber.org/zap"
+	"os"
 )
 
 const (

diff --git a/go/services/cluster_metadata/pkg/services/metadata_service.go b/go/services/cluster_metadata/pkg/services/metadata_service.go
@@ -27,7 +27,7 @@ const (
 	NODE_AGENT_METADATA_TOPIC_ENV_NAME                  = "NODE_AGENT_NODE_METADATA_TOPIC"
 )
 
-func NewApplicationMetadataBroker(logger *zap.Logger, creds *messagebroker.KafkaCredentials) *messagebroker.KafkaJsonMessageBroker[repositories.ApplicationState] {
+func NewApplicationMetadataBroker(logger *zap.Logger, creds *messagebroker.KafkaCredentials) messagebroker.MessageBroker[repositories.ApplicationState] {
 	envs.ValidateEnvs("%s env variable not set", []string{
 		POD_AGENT_APPLICATION_METADATA_TOPIC_ENV_NAME,
 	})
@@ -40,7 +40,7 @@ func NewApplicationMetadataBroker(logger *zap.Logger, creds *messagebroker.Kafka
 	)
 }
 
-func NewNodeMetadataBroker(logger *zap.Logger, creds *messagebroker.KafkaCredentials) *messagebroker.KafkaJsonMessageBroker[repositories.NodeState] {
+func NewNodeMetadataBroker(logger *zap.Logger, creds *messagebroker.KafkaCredentials) messagebroker.MessageBroker[repositories.NodeState] {
 	envs.ValidateEnvs("%s env variable not set", []string{
 		NODE_AGENT_METADATA_TOPIC_ENV_NAME,
 	})