update atomic operation

add using lazy connect
2024-11-26 16:53:45 +03:00
1 changed files with 2 additions and 2 deletions
--- a/redis.go
+++ b/redis.go
@@ -770,9 +770,9 @@ func (r *Store) getKey(b *strings.Builder, mainNamespace string, opNamespace str
 	return b.String()
 }

-func (r *Store) connect(ctx context.Context) error {
+func (r *Store) connect(ctx context.Context) (err error) {
 	if r.isConnected.Load() == 0 {
-		if err := r.cli.Ping(ctx).Err(); err != nil {
+		if err = r.cli.Ping(ctx).Err(); err != nil {
 			setSpanError(ctx, err)
 			return err
 		}