|
|
@ -132,7 +132,7 @@ func ProvideService(plugCtxProvider *plugincontext.Provider, cfg *setting.Cfg, r |
|
|
|
// globally since kept inside Redis.
|
|
|
|
// globally since kept inside Redis.
|
|
|
|
err := setupRedisLiveEngine(g, node) |
|
|
|
err := setupRedisLiveEngine(g, node) |
|
|
|
if err != nil { |
|
|
|
if err != nil { |
|
|
|
logger.Error("failed to setup redis live engine: %v", err) |
|
|
|
logger.Error("failed to setup redis live engine", "error", err) |
|
|
|
} else { |
|
|
|
} else { |
|
|
|
redisHealthy = true |
|
|
|
redisHealthy = true |
|
|
|
} |
|
|
|
} |
|
|
@ -149,7 +149,7 @@ func ProvideService(plugCtxProvider *plugincontext.Provider, cfg *setting.Cfg, r |
|
|
|
}) |
|
|
|
}) |
|
|
|
cmd := redisClient.Ping(context.Background()) |
|
|
|
cmd := redisClient.Ping(context.Background()) |
|
|
|
if _, err := cmd.Result(); err != nil { |
|
|
|
if _, err := cmd.Result(); err != nil { |
|
|
|
logger.Error("live engine failed to ping redis, proceeding without live ha, error: %v", err) |
|
|
|
logger.Error("live engine failed to ping redis, proceeding without live ha", "error", err) |
|
|
|
redisClient = nil |
|
|
|
redisClient = nil |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|