Skip to content

Commit

Permalink
Update storage/redis_cluster.go
Browse files Browse the repository at this point in the history
  • Loading branch information
sweep-ai[bot] committed Aug 8, 2023
1 parent b8edcef commit ec634d0
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion storage/redis_cluster.go
Expand Up @@ -183,6 +183,7 @@ func (r *RedisCluster) cleanKey(keyName string) string {

func (r *RedisCluster) up() error {
if !r.RedisController.Connected() {
log.Error("Redis server is not available")
return ErrRedisIsDown
}
return nil
Expand Down Expand Up @@ -801,4 +802,4 @@ func (r *RedisCluster) handleReceive(ctx context.Context, receiveFn func(context
func (r *RedisCluster) handleMessage(msg interface{}, err error, callback func(interface{})) error {
if err == nil {
if callback != nil {
callback(msg)
callback(msg)

0 comments on commit ec634d0

Please sign in to comment.