fix: correct compile issues

snapp-incubator · Oct 2, 2024 · 7782b48 · 7782b48
1 parent 29c223a
commit 7782b48
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/internal/client/jetstream.go b/internal/client/jetstream.go
@@ -158,7 +158,7 @@ func (client *Client) createSubscribe(ctx context.Context, subject string) <-cha
 	con, err := client.jetstream.CreateOrUpdateConsumer(
 		ctx,
 		subject,
-		jetstream.ConsumerConfig{
+		jetstream.ConsumerConfig{ // nolint: exhaustruct
 			DeliverPolicy: jetstream.DeliverNewPolicy,
 			ReplayPolicy:  jetstream.ReplayInstantPolicy,
 			AckPolicy:     jetstream.AckExplicitPolicy,

diff --git a/internal/cmd/main.go b/internal/cmd/main.go
@@ -1,6 +1,7 @@
 package cmd
 
 import (
+	"context"
 	"os"
 	"os/signal"
 	"syscall"
@@ -11,8 +12,9 @@ import (
 )
 
 func main(cfg config.Config, logger *zap.Logger) {
+	ctx := context.Background()
 	jetstreamClient := client.New(cfg.NATS, logger)
-	jetstreamClient.StartBlackboxTest()
+	jetstreamClient.StartBlackboxTest(ctx)
 
 	sig := make(chan os.Signal, 1)
 	signal.Notify(sig, syscall.SIGINT, syscall.SIGTERM)