emit number of active replicas metrics instead

This commit is contained in:
zliang committed 2023-11-27 17:01:04 -07:00
1 parent 20ae39d643
commit 8fec9ba466
1 file changed
+2 -8
+2 -8
View File
@@ -564,14 +564,8 @@ void emit_metrics_for_insufficient_replicas(struct RedisModuleCtx *ctx, long lon
// check if the current node is a primary
if (strncmp(role, "master", len) == 0) {
RedisModuleCallReply *replicasReply = RedisModule_CallReplyArrayElement(reply, 2);
// check if there are less than 2 connected replicas
size_t numberOfReplicas = RedisModule_CallReplyLength(replicasReply);
if (numberOfReplicas == 0) {
g_stats->increment("lessThanExpectedReplicas_noReplicas_criticalError", 1);
}
else if (numberOfReplicas == 1) {
g_stats->increment("lessThanExpectedReplicas_1ReplicaLeft_error", 1);
}
size_t numberOfActiveReplicas = RedisModule_CallReplyLength(replicasReply);
g_stats->gauge("numberOfActiveReplicas", numberOfActiveReplicas);
}
RedisModule_FreeCallReply(reply);
}