Skip to content

Commit

Permalink
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
MQBSTAT: extend json queue metrics
Browse files Browse the repository at this point in the history
Signed-off-by: Evgeny Malygin <emalygin@bloomberg.net>
678098 committed Aug 13, 2024

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature.
1 parent a0af51c commit 102331e
Showing 2 changed files with 194 additions and 0 deletions.
34 changes: 34 additions & 0 deletions src/groups/mqb/mqbstat/mqbstat_jsonprinter.cpp
Original file line number Diff line number Diff line change
@@ -74,17 +74,51 @@ struct ConversionUtils {

populateMetric(&values, ctx, Stat::e_NB_PRODUCER);
populateMetric(&values, ctx, Stat::e_NB_CONSUMER);

populateMetric(&values, ctx, Stat::e_MESSAGES_CURRENT);
populateMetric(&values, ctx, Stat::e_MESSAGES_MAX);
populateMetric(&values, ctx, Stat::e_BYTES_CURRENT);
populateMetric(&values, ctx, Stat::e_BYTES_MAX);

populateMetric(&values, ctx, Stat::e_PUT_MESSAGES_DELTA);
populateMetric(&values, ctx, Stat::e_PUT_BYTES_DELTA);
populateMetric(&values, ctx, Stat::e_PUT_MESSAGES_ABS);
populateMetric(&values, ctx, Stat::e_PUT_BYTES_ABS);

populateMetric(&values, ctx, Stat::e_PUSH_MESSAGES_DELTA);
populateMetric(&values, ctx, Stat::e_PUSH_BYTES_DELTA);
populateMetric(&values, ctx, Stat::e_PUSH_MESSAGES_ABS);
populateMetric(&values, ctx, Stat::e_PUSH_BYTES_ABS);

populateMetric(&values, ctx, Stat::e_ACK_DELTA);
populateMetric(&values, ctx, Stat::e_ACK_ABS);
populateMetric(&values, ctx, Stat::e_ACK_TIME_AVG);
populateMetric(&values, ctx, Stat::e_ACK_TIME_MAX);

populateMetric(&values, ctx, Stat::e_NACK_DELTA);
populateMetric(&values, ctx, Stat::e_NACK_ABS);

populateMetric(&values, ctx, Stat::e_CONFIRM_DELTA);
populateMetric(&values, ctx, Stat::e_CONFIRM_ABS);
populateMetric(&values, ctx, Stat::e_CONFIRM_TIME_AVG);
populateMetric(&values, ctx, Stat::e_CONFIRM_TIME_MAX);

populateMetric(&values, ctx, Stat::e_REJECT_ABS);
populateMetric(&values, ctx, Stat::e_REJECT_DELTA);

populateMetric(&values, ctx, Stat::e_QUEUE_TIME_AVG);
populateMetric(&values, ctx, Stat::e_QUEUE_TIME_MAX);

populateMetric(&values, ctx, Stat::e_GC_MSGS_DELTA);
populateMetric(&values, ctx, Stat::e_GC_MSGS_ABS);

populateMetric(&values, ctx, Stat::e_ROLE);

populateMetric(&values, ctx, Stat::e_CFG_MSGS);
populateMetric(&values, ctx, Stat::e_CFG_BYTES);

populateMetric(&values, ctx, Stat::e_NO_SC_MSGS_DELTA);
populateMetric(&values, ctx, Stat::e_NO_SC_MSGS_ABS);
}

inline static void populateOneDomainStats(bdljsn::JsonObject* domainObject,
160 changes: 160 additions & 0 deletions src/python/blazingmq/dev/it/data/data_metrics.py
Original file line number Diff line number Diff line change
@@ -56,77 +56,157 @@ def check(self, value: Any) -> bool:
"bar": {
"values": {
"queue_ack_msgs": 0,
"queue_ack_msgs_abs": 0,
"queue_ack_time_avg": 0,
"queue_ack_time_max": 0,
"queue_bytes_current": 96,
"queue_cfg_bytes": 0,
"queue_cfg_msgs": 0,
"queue_confirm_msgs": 0,
"queue_confirm_msgs_abs": 0,
"queue_confirm_time_avg": 0,
"queue_confirm_time_max": 0,
"queue_consumers_count": 0,
"queue_content_bytes": 96,
"queue_content_msgs": 32,
"queue_gc_msgs": 0,
"queue_gc_msgs_abs": 0,
"queue_msgs_current": 32,
"queue_nack_msgs": 0,
"queue_nack_msgs_abs": 0,
"queue_nack_noquorum_msgs": 0,
"queue_nack_noquorum_msgs_abs": 0,
"queue_producers_count": 0,
"queue_push_bytes": 0,
"queue_push_bytes_abs": 0,
"queue_push_msgs": 0,
"queue_push_msgs_abs": 0,
"queue_put_bytes": 0,
"queue_put_bytes_abs": 0,
"queue_put_msgs": 0,
"queue_put_msgs_abs": 0,
"queue_queue_time_avg": 0,
"queue_queue_time_max": 0,
"queue_reject_msgs": 0,
"queue_reject_msgs_abs": 0,
"queue_role": 0,
}
},
"baz": {
"values": {
"queue_ack_msgs": 0,
"queue_ack_msgs_abs": 0,
"queue_ack_time_avg": 0,
"queue_ack_time_max": 0,
"queue_bytes_current": 96,
"queue_cfg_bytes": 0,
"queue_cfg_msgs": 0,
"queue_confirm_msgs": 0,
"queue_confirm_msgs_abs": 0,
"queue_confirm_time_avg": 0,
"queue_confirm_time_max": 0,
"queue_consumers_count": 0,
"queue_content_bytes": 96,
"queue_content_msgs": 32,
"queue_gc_msgs": 0,
"queue_gc_msgs_abs": 0,
"queue_msgs_current": 32,
"queue_nack_msgs": 0,
"queue_nack_msgs_abs": 0,
"queue_nack_noquorum_msgs": 0,
"queue_nack_noquorum_msgs_abs": 0,
"queue_producers_count": 0,
"queue_push_bytes": 0,
"queue_push_bytes_abs": 0,
"queue_push_msgs": 0,
"queue_push_msgs_abs": 0,
"queue_put_bytes": 0,
"queue_put_bytes_abs": 0,
"queue_put_msgs": 0,
"queue_put_msgs_abs": 0,
"queue_queue_time_avg": 0,
"queue_queue_time_max": 0,
"queue_reject_msgs": 0,
"queue_reject_msgs_abs": 0,
"queue_role": 0,
}
},
"foo": {
"values": {
"queue_ack_msgs": 0,
"queue_ack_msgs_abs": 0,
"queue_ack_time_avg": 0,
"queue_ack_time_max": 0,
"queue_bytes_current": 96,
"queue_cfg_bytes": 0,
"queue_cfg_msgs": 0,
"queue_confirm_msgs": 0,
"queue_confirm_msgs_abs": 0,
"queue_confirm_time_avg": 0,
"queue_confirm_time_max": 0,
"queue_consumers_count": 0,
"queue_content_bytes": 96,
"queue_content_msgs": 32,
"queue_gc_msgs": 0,
"queue_gc_msgs_abs": 0,
"queue_msgs_current": 32,
"queue_nack_msgs": 0,
"queue_nack_msgs_abs": 0,
"queue_nack_noquorum_msgs": 0,
"queue_nack_noquorum_msgs_abs": 0,
"queue_producers_count": 0,
"queue_push_bytes": 0,
"queue_push_bytes_abs": 0,
"queue_push_msgs": 0,
"queue_push_msgs_abs": 0,
"queue_put_bytes": 0,
"queue_put_bytes_abs": 0,
"queue_put_msgs": 0,
"queue_put_msgs_abs": 0,
"queue_queue_time_avg": 0,
"queue_queue_time_max": 0,
"queue_reject_msgs": 0,
"queue_reject_msgs_abs": 0,
"queue_role": 0,
}
},
},
"values": {
"queue_ack_msgs": 32,
"queue_ack_msgs_abs": 32,
"queue_ack_time_avg": GreaterThan(0),
"queue_ack_time_max": GreaterThan(0),
"queue_bytes_current": 96,
"queue_cfg_bytes": 1048576,
"queue_cfg_msgs": 1000,
"queue_confirm_msgs": 0,
"queue_confirm_msgs_abs": 0,
"queue_confirm_time_avg": 0,
"queue_confirm_time_max": 0,
"queue_consumers_count": 0,
"queue_content_bytes": 96,
"queue_content_msgs": 32,
"queue_gc_msgs": 0,
"queue_gc_msgs_abs": 0,
"queue_msgs_current": 32,
"queue_nack_msgs": 0,
"queue_nack_msgs_abs": 0,
"queue_nack_noquorum_msgs": 0,
"queue_nack_noquorum_msgs_abs": 0,
"queue_producers_count": 0,
"queue_push_bytes": 0,
"queue_push_bytes_abs": 0,
"queue_push_msgs": 0,
"queue_push_msgs_abs": 0,
"queue_put_bytes": 96,
"queue_put_bytes_abs": 96,
"queue_put_msgs": 32,
"queue_put_msgs_abs": 32,
"queue_queue_time_avg": 0,
"queue_queue_time_max": 0,
"queue_reject_msgs": 0,
"queue_reject_msgs_abs": 0,
"queue_role": 1,
},
}

@@ -135,77 +215,157 @@ def check(self, value: Any) -> bool:
"bar": {
"values": {
"queue_ack_msgs": 0,
"queue_ack_msgs_abs": 0,
"queue_ack_time_avg": 0,
"queue_ack_time_max": 0,
"queue_bytes_current": 30,
"queue_cfg_bytes": 0,
"queue_cfg_msgs": 0,
"queue_confirm_msgs": 0,
"queue_confirm_msgs_abs": 0,
"queue_confirm_time_avg": GreaterThan(0),
"queue_confirm_time_max": GreaterThan(0),
"queue_consumers_count": 0,
"queue_content_bytes": 96,
"queue_content_msgs": 32,
"queue_gc_msgs": 0,
"queue_gc_msgs_abs": 0,
"queue_msgs_current": 10,
"queue_nack_msgs": 0,
"queue_nack_msgs_abs": 0,
"queue_nack_noquorum_msgs": 0,
"queue_nack_noquorum_msgs_abs": 0,
"queue_producers_count": 0,
"queue_push_bytes": 0,
"queue_push_bytes_abs": 0,
"queue_push_msgs": 0,
"queue_push_msgs_abs": 0,
"queue_put_bytes": 0,
"queue_put_bytes_abs": 0,
"queue_put_msgs": 0,
"queue_put_msgs_abs": 0,
"queue_queue_time_avg": GreaterThan(0),
"queue_queue_time_max": GreaterThan(0),
"queue_reject_msgs": 0,
"queue_reject_msgs_abs": 0,
"queue_role": 0,
}
},
"baz": {
"values": {
"queue_ack_msgs": 0,
"queue_ack_msgs_abs": 0,
"queue_ack_time_avg": 0,
"queue_ack_time_max": 0,
"queue_bytes_current": 63,
"queue_cfg_bytes": 0,
"queue_cfg_msgs": 0,
"queue_confirm_msgs": 0,
"queue_confirm_msgs_abs": 0,
"queue_confirm_time_avg": GreaterThan(0),
"queue_confirm_time_max": GreaterThan(0),
"queue_consumers_count": 0,
"queue_content_bytes": 96,
"queue_content_msgs": 32,
"queue_gc_msgs": 0,
"queue_gc_msgs_abs": 0,
"queue_msgs_current": 21,
"queue_nack_msgs": 0,
"queue_nack_msgs_abs": 0,
"queue_nack_noquorum_msgs": 0,
"queue_nack_noquorum_msgs_abs": 0,
"queue_producers_count": 0,
"queue_push_bytes": 0,
"queue_push_bytes_abs": 0,
"queue_push_msgs": 0,
"queue_push_msgs_abs": 0,
"queue_put_bytes": 0,
"queue_put_bytes_abs": 0,
"queue_put_msgs": 0,
"queue_put_msgs_abs": 0,
"queue_queue_time_avg": GreaterThan(0),
"queue_queue_time_max": GreaterThan(0),
"queue_reject_msgs": 0,
"queue_reject_msgs_abs": 0,
"queue_role": 0,
}
},
"foo": {
"values": {
"queue_ack_msgs": 0,
"queue_ack_msgs_abs": 0,
"queue_ack_time_avg": 0,
"queue_ack_time_max": 0,
"queue_bytes_current": 0,
"queue_cfg_bytes": 0,
"queue_cfg_msgs": 0,
"queue_confirm_msgs": 0,
"queue_confirm_msgs_abs": 0,
"queue_confirm_time_avg": GreaterThan(0),
"queue_confirm_time_max": GreaterThan(0),
"queue_consumers_count": 0,
"queue_content_bytes": 96,
"queue_content_msgs": 32,
"queue_gc_msgs": 0,
"queue_gc_msgs_abs": 0,
"queue_msgs_current": 0,
"queue_nack_msgs": 0,
"queue_nack_msgs_abs": 0,
"queue_nack_noquorum_msgs": 0,
"queue_nack_noquorum_msgs_abs": 0,
"queue_producers_count": 0,
"queue_push_bytes": 0,
"queue_push_bytes_abs": 0,
"queue_push_msgs": 0,
"queue_push_msgs_abs": 0,
"queue_put_bytes": 0,
"queue_put_bytes_abs": 0,
"queue_put_msgs": 0,
"queue_put_msgs_abs": 0,
"queue_queue_time_avg": GreaterThan(0),
"queue_queue_time_max": GreaterThan(0),
"queue_reject_msgs": 0,
"queue_reject_msgs_abs": 0,
"queue_role": 0,
}
},
},
"values": {
"queue_ack_msgs": 32,
"queue_ack_msgs_abs": 32,
"queue_ack_time_avg": GreaterThan(0),
"queue_ack_time_max": GreaterThan(0),
"queue_bytes_current": 63,
"queue_cfg_bytes": 1048576,
"queue_cfg_msgs": 1000,
"queue_confirm_msgs": 65,
"queue_confirm_msgs_abs": 65,
"queue_confirm_time_avg": GreaterThan(0),
"queue_confirm_time_max": GreaterThan(0),
"queue_consumers_count": 3,
"queue_content_bytes": 96,
"queue_content_msgs": 32,
"queue_gc_msgs": 0,
"queue_gc_msgs_abs": 0,
"queue_msgs_current": 21,
"queue_nack_msgs": 0,
"queue_nack_msgs_abs": 0,
"queue_nack_noquorum_msgs": 0,
"queue_nack_noquorum_msgs_abs": 0,
"queue_producers_count": 0,
"queue_push_bytes": 288,
"queue_push_bytes_abs": 288,
"queue_push_msgs": 96,
"queue_push_msgs_abs": 96,
"queue_put_bytes": 96,
"queue_put_bytes_abs": 96,
"queue_put_msgs": 32,
"queue_put_msgs_abs": 32,
"queue_queue_time_avg": GreaterThan(0),
"queue_queue_time_max": GreaterThan(0),
"queue_reject_msgs": 0,
"queue_reject_msgs_abs": 0,
"queue_role": 1,
},
}

0 comments on commit 102331e

Please sign in to comment.