From 3ea4a965917b0659b82e25444eca47c9ee0637b8 Mon Sep 17 00:00:00 2001 From: slaventius Date: Wed, 1 Mar 2023 12:06:39 +0300 Subject: [PATCH] * --- internal/authDB.go | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/internal/authDB.go b/internal/authDB.go index 783c271..0736cd9 100644 --- a/internal/authDB.go +++ b/internal/authDB.go @@ -23,13 +23,12 @@ import ( ) type AuthDBServer struct { + ctx context.Context kafkaWriter *kafka.KafkaWriter logger *logger.Logger repo *repo.CustomerRepository api.UnimplementedAuthDBServer api.UnimplementedHealthServer - ctx context.Context - id int32 } func NewServer(ctx context.Context, config *config.Config) *AuthDBServer { @@ -46,11 +45,10 @@ func NewServer(ctx context.Context, config *config.Config) *AuthDBServer { } return &AuthDBServer{ + ctx: ctx, repo: repo, kafkaWriter: kafka.NewWriter(ctx, logger, apiKafka.TopicRegistrations, net.JoinHostPort(config.Kafka.Host, strconv.Itoa(config.Kafka.Port))), logger: logger, - ctx: ctx, - id: 0, } }