Delay reconnect log (#2636)

* delay logging of reconnect msg to 1 second Signed-off-by: jkoberg <[email protected]> * add changelog Signed-off-by: jkoberg <[email protected]> * address TODO Signed-off-by: jkoberg <[email protected]>
cs3org · Mar 15, 2022 · 6a598b8 · 6a598b8
1 parent d008faf
commit 6a598b8
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 4 deletions.
diff --git a/changelog/unreleased/delay-reconnect-log.md b/changelog/unreleased/delay-reconnect-log.md
@@ -0,0 +1,5 @@
+Bugfix: delay reconnect log for events
+
+Print reconnect information log only when reconnect time is bigger than a second
+
+https://github.com/cs3org/reva/pull/2636
diff --git a/pkg/events/server/nats.go b/pkg/events/server/nats.go
@@ -19,10 +19,11 @@
 package server
 
 import (
-	"fmt"
+	"time"
 
 	"github.com/asim/go-micro/plugins/events/nats/v4"
 	"github.com/cenkalti/backoff"
+	"github.com/cs3org/reva/v2/pkg/logger"
 	"go-micro.dev/v4/events"
 
 	stanServer "github.com/nats-io/nats-streaming-server/server"
@@ -46,10 +47,10 @@ func NewNatsStream(opts ...nats.Option) (events.Stream, error) {
 	b := backoff.NewExponentialBackOff()
 	var stream events.Stream
 	o := func() error {
+		n := b.NextBackOff()
 		s, err := nats.NewStream(opts...)
-		if err != nil {
-			// TODO: should we get the standard logger here? if yes: How?
-			fmt.Printf("can't connect to nats (stan) server, retrying in %s\n", b.NextBackOff())
+		if err != nil && n > time.Second {
+			logger.New().Error().Err(err).Msgf("can't connect to nats (stan) server, retrying in %s", n)
 		}
 		stream = s
 		return err