From 395316cfb4a568ed3e9f92be8acc36043c389b14 Mon Sep 17 00:00:00 2001 From: Andreas Holstenson Date: Sun, 14 Jan 2024 16:44:21 +0100 Subject: [PATCH] test: Upgrade NATS server version --- go.mod | 2 +- go.sum | 4 ++-- internal/events/streams_test.go | 8 ++++---- 3 files changed, 7 insertions(+), 7 deletions(-) diff --git a/go.mod b/go.mod index 220ea80..cd7c382 100644 --- a/go.mod +++ b/go.mod @@ -7,7 +7,7 @@ require ( github.com/google/uuid v1.5.0 github.com/grpc-ecosystem/go-grpc-middleware/v2 v2.0.1 github.com/levelfourab/sprout-go v0.14.0 - github.com/nats-io/nats-server/v2 v2.10.7 + github.com/nats-io/nats-server/v2 v2.10.9 github.com/nats-io/nats.go v1.32.0 github.com/onsi/ginkgo/v2 v2.13.2 github.com/onsi/gomega v1.30.0 diff --git a/go.sum b/go.sum index c5a7c8f..d441628 100644 --- a/go.sum +++ b/go.sum @@ -86,8 +86,8 @@ github.com/minio/highwayhash v1.0.2 h1:Aak5U0nElisjDCfPSG79Tgzkn2gl66NxOMspRrKnA github.com/minio/highwayhash v1.0.2/go.mod h1:BQskDq+xkJ12lmlUUi7U0M5Swg3EWR+dLTk+kldvVxY= github.com/nats-io/jwt/v2 v2.5.3 h1:/9SWvzc6hTfamcgXJ3uYRpgj+QuY2aLNqRiqrKcrpEo= github.com/nats-io/jwt/v2 v2.5.3/go.mod h1:iysuPemFcc7p4IoYots3IuELSI4EDe9Y0bQMe+I3Bf4= -github.com/nats-io/nats-server/v2 v2.10.7 h1:f5VDy+GMu7JyuFA0Fef+6TfulfCs5nBTgq7MMkFJx5Y= -github.com/nats-io/nats-server/v2 v2.10.7/go.mod h1:V2JHOvPiPdtfDXTuEUsthUnCvSDeFrK4Xn9hRo6du7c= +github.com/nats-io/nats-server/v2 v2.10.9 h1:VEW43Zz+p+9lARtiPM9ctd6ckun+92ZT2T17HWtwiFI= +github.com/nats-io/nats-server/v2 v2.10.9/go.mod h1:oorGiV9j3BOLLO3ejQe+U7pfAGyPo+ppD7rpgNF6KTQ= github.com/nats-io/nats.go v1.32.0 h1:Bx9BZS+aXYlxW08k8Gd3yR2s73pV5XSoAQUyp1Kwvp0= github.com/nats-io/nats.go v1.32.0/go.mod h1:Ubdu4Nh9exXdSz0RVWRFBbRfrbSxOYd26oF0wkWclB8= github.com/nats-io/nkeys v0.4.7 h1:RwNJbbIdYCoClSDNY7QVKZlyb/wfT6ugvFCiKy6vDvI= diff --git a/internal/events/streams_test.go b/internal/events/streams_test.go index 63a4614..1af42e2 100644 --- a/internal/events/streams_test.go +++ b/internal/events/streams_test.go @@ -475,7 +475,7 @@ var _ = Describe("Streams", func() { }) Expect(err).ToNot(HaveOccurred()) - time.Sleep(100 * time.Millisecond) + time.Sleep(200 * time.Millisecond) // Verify that the mirror stream has the message stream, err := js.Stream(ctx, "test-mirror") @@ -509,7 +509,7 @@ var _ = Describe("Streams", func() { }) Expect(err).ToNot(HaveOccurred()) - time.Sleep(100 * time.Millisecond) + time.Sleep(200 * time.Millisecond) // Verify that the mirror stream has the message stream, err := js.Stream(ctx, "test-mirror") @@ -573,7 +573,7 @@ var _ = Describe("Streams", func() { }) Expect(err).ToNot(HaveOccurred()) - time.Sleep(100 * time.Millisecond) + time.Sleep(200 * time.Millisecond) // Verify that the mirror stream has the message stream, err := js.Stream(ctx, "test-mirror") @@ -637,7 +637,7 @@ var _ = Describe("Streams", func() { }) Expect(err).ToNot(HaveOccurred()) - time.Sleep(100 * time.Millisecond) + time.Sleep(200 * time.Millisecond) // Verify that the mirror stream does not hav the message stream, err := js.Stream(ctx, "test-mirror")