feat: update dal

Bisonai · Aug 14, 2024 · 1f631cc · 1f631cc
1 parent ebc6a30
commit 1f631cc
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 0 deletions.
diff --git a/node/pkg/dal/collector/collector.go b/node/pkg/dal/collector/collector.go
@@ -174,6 +174,8 @@ func (c *Collector) receive(ctx context.Context) {
 	go c.baseRediscribe.Start(ctx)
 
 	if c.subRediscribe != nil {
+		// wait for sidecar to be ready
+		time.Sleep(10 * time.Second)
 		go c.subRediscribe.Start(ctx)
 	}
 }

diff --git a/node/pkg/db/redis.go b/node/pkg/db/redis.go
@@ -5,6 +5,7 @@ import (
 	"encoding/json"
 	"errors"
 	"os"
+	"strings"
 	"sync"
 	"time"
 
@@ -113,6 +114,15 @@ func isConnectionError(err error) bool {
 	if errors.Is(err, redis.Nil) {
 		return false
 	}
+
+	if errors.Is(err, redis.ErrClosed) {
+		return true
+	}
+
+	if strings.Contains(err.Error(), "i/o timeout") {
+		return true
+	}
+
 	return err == redis.TxFailedErr || err.Error() == "redis: connection closed"
 }