fix concourse linter issues

ONSdigital · Feb 27, 2023 · e0b85b2 · e0b85b2
1 parent d7c9ff3
commit e0b85b2
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 3 deletions.
diff --git a/service/interfaces.go b/service/interfaces.go
@@ -5,6 +5,7 @@ import (
 	"net/http"
 
 	"github.com/ONSdigital/dp-healthcheck/healthcheck"
+	kafka "github.com/ONSdigital/dp-kafka/v3"
 )
 
 //go:generate moq -out mock/server.go -pkg mock . HTTPServer
@@ -24,3 +25,9 @@ type HealthChecker interface {
 	AddAndGetCheck(name string, checker healthcheck.Checker) (check *healthcheck.Check, err error)
 	Subscribe(s healthcheck.Subscriber, checks ...*healthcheck.Check)
 }
+
+// kafkaConsumerGroup is an alias to dp-kafka IConsumerGroup interface
+type kafkaConsumerGroup kafka.IConsumerGroup
+
+// kafkaProducer is an alias to dp-kafka IProducer interface
+type kafkaProducer kafka.IProducer
diff --git a/service/service.go b/service/service.go
@@ -4,7 +4,6 @@ import (
 	"context"
 	"fmt"
 
-	kafka "github.com/ONSdigital/dp-kafka/v3"
 	"github.com/ONSdigital/dp-search-data-extractor/clients"
 	"github.com/ONSdigital/dp-search-data-extractor/config"
 	"github.com/ONSdigital/dp-search-data-extractor/handler"
@@ -18,8 +17,8 @@ type Service struct {
 	Cfg         *config.Config
 	Server      HTTPServer
 	HealthCheck HealthChecker
-	Consumer    kafka.IConsumerGroup
-	Producer    kafka.IProducer
+	Consumer    kafkaConsumerGroup
+	Producer    kafkaProducer
 	ZebedeeCli  clients.ZebedeeClient
 	DatasetCli  clients.DatasetClient
 }