Skip to content

Commit

Permalink
Update queue metrics IT
Browse files Browse the repository at this point in the history 
Signed-off-by: Evgeny Malygin <[email protected]>
  • Loading branch information
@678098
678098 committed Jul 5, 2024
1 parent 3ba2c6f commit 90a7c9e
Show file tree
Hide file tree
Showing 2 changed files with 74 additions and 52 deletions.
14 changes: 10 additions & 4 deletions src/groups/mqb/mqbstat/mqbstat_jsonprinter.cpp
View file
Original file line number Diff line number Diff line change
Expand Up @@ -107,10 +107,14 @@ class JsonPrinterImpl {

inline JsonPrinterImpl::JsonPrinterImpl(const StatContextsMap& statContextsMap,
bslma::Allocator* allocator)
: d_opsCompact(bdljsn::WriteOptions().setSpacesPerLevel(0).setStyle(
bdljsn::WriteStyle::e_COMPACT))
, d_opsPretty(bdljsn::WriteOptions().setSpacesPerLevel(4).setStyle(
bdljsn::WriteStyle::e_PRETTY))
: d_opsCompact(bdljsn::WriteOptions()
.setSpacesPerLevel(0)
.setStyle(bdljsn::WriteStyle::e_COMPACT)
.setSortMembers(true))
, d_opsPretty(bdljsn::WriteOptions()
.setSpacesPerLevel(4)
.setStyle(bdljsn::WriteStyle::e_PRETTY)
.setSortMembers(true))
, d_contexts(statContextsMap, allocator)
{
// NOTHING
Expand Down Expand Up @@ -149,6 +153,8 @@ JsonPrinterImpl::populateQueueStats(bdljsn::JsonObject* queueObject,

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_BYTES_CURRENT);
populateMetric(&values, ctx, Stat::e_PUT_MESSAGES_DELTA);
populateMetric(&values, ctx, Stat::e_PUT_BYTES_DELTA);
populateMetric(&values, ctx, Stat::e_PUSH_MESSAGES_DELTA);
Expand Down
112 changes: 64 additions & 48 deletions src/python/blazingmq/dev/it/data/data_metrics.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -55,68 +55,76 @@ def check(self, value: Any) -> bool:
"appIds": {
"bar": {
"values": {
"queue_confirm_time_max": 0,
"queue_confirm_time_avg": 0,
"queue_nack_msgs": 0,
"queue_ack_time_max": 0,
"queue_ack_msgs": 0,
"queue_ack_time_avg": 0,
"queue_ack_time_max": 0,
"queue_bytes_current": 96,
"queue_confirm_msgs": 0,
"queue_push_bytes": 0,
"queue_confirm_time_avg": 0,
"queue_confirm_time_max": 0,
"queue_consumers_count": 0,
"queue_msgs_current": 32,
"queue_nack_msgs": 0,
"queue_producers_count": 0,
"queue_push_bytes": 0,
"queue_push_msgs": 0,
"queue_ack_time_avg": 0,
"queue_put_bytes": 0,
"queue_put_msgs": 0,
}
},
"baz": {
"values": {
"queue_confirm_time_max": 0,
"queue_confirm_time_avg": 0,
"queue_nack_msgs": 0,
"queue_ack_time_max": 0,
"queue_ack_msgs": 0,
"queue_ack_time_avg": 0,
"queue_ack_time_max": 0,
"queue_bytes_current": 96,
"queue_confirm_msgs": 0,
"queue_push_bytes": 0,
"queue_confirm_time_avg": 0,
"queue_confirm_time_max": 0,
"queue_consumers_count": 0,
"queue_msgs_current": 32,
"queue_nack_msgs": 0,
"queue_producers_count": 0,
"queue_push_bytes": 0,
"queue_push_msgs": 0,
"queue_ack_time_avg": 0,
"queue_put_bytes": 0,
"queue_put_msgs": 0,
}
},
"foo": {
"values": {
"queue_confirm_time_max": 0,
"queue_confirm_time_avg": 0,
"queue_nack_msgs": 0,
"queue_ack_time_max": 0,
"queue_ack_msgs": 0,
"queue_ack_time_avg": 0,
"queue_ack_time_max": 0,
"queue_bytes_current": 96,
"queue_confirm_msgs": 0,
"queue_push_bytes": 0,
"queue_confirm_time_avg": 0,
"queue_confirm_time_max": 0,
"queue_consumers_count": 0,
"queue_msgs_current": 32,
"queue_nack_msgs": 0,
"queue_producers_count": 0,
"queue_push_bytes": 0,
"queue_push_msgs": 0,
"queue_ack_time_avg": 0,
"queue_put_bytes": 0,
"queue_put_msgs": 0,
}
},
},
"values": {
"queue_confirm_time_max": 0,
"queue_confirm_time_avg": 0,
"queue_nack_msgs": 0,
"queue_ack_time_max": GreaterThan(0),
"queue_ack_msgs": 32,
"queue_ack_time_avg": GreaterThan(0),
"queue_ack_time_max": GreaterThan(0),
"queue_bytes_current": 96,
"queue_confirm_msgs": 0,
"queue_push_bytes": 0,
"queue_confirm_time_avg": 0,
"queue_confirm_time_max": 0,
"queue_consumers_count": 0,
"queue_msgs_current": 32,
"queue_nack_msgs": 0,
"queue_producers_count": 0,
"queue_push_bytes": 0,
"queue_push_msgs": 0,
"queue_ack_time_avg": GreaterThan(0),
"queue_put_bytes": 96,
"queue_put_msgs": 32,
},
Expand All @@ -126,68 +134,76 @@ def check(self, value: Any) -> bool:
"appIds": {
"bar": {
"values": {
"queue_confirm_time_max": GreaterThan(0),
"queue_confirm_time_avg": GreaterThan(0),
"queue_nack_msgs": 0,
"queue_ack_time_max": 0,
"queue_ack_msgs": 0,
"queue_ack_time_avg": 0,
"queue_ack_time_max": 0,
"queue_bytes_current": 30,
"queue_confirm_msgs": 0,
"queue_push_bytes": 0,
"queue_confirm_time_avg": GreaterThan(0),
"queue_confirm_time_max": GreaterThan(0),
"queue_consumers_count": 0,
"queue_msgs_current": 10,
"queue_nack_msgs": 0,
"queue_producers_count": 0,
"queue_push_bytes": 0,
"queue_push_msgs": 0,
"queue_ack_time_avg": 0,
"queue_put_bytes": 0,
"queue_put_msgs": 0,
}
},
"baz": {
"values": {
"queue_confirm_time_max": GreaterThan(0),
"queue_confirm_time_avg": GreaterThan(0),
"queue_nack_msgs": 0,
"queue_ack_time_max": 0,
"queue_ack_msgs": 0,
"queue_ack_time_avg": 0,
"queue_ack_time_max": 0,
"queue_bytes_current": 63,
"queue_confirm_msgs": 0,
"queue_push_bytes": 0,
"queue_confirm_time_avg": GreaterThan(0),
"queue_confirm_time_max": GreaterThan(0),
"queue_consumers_count": 0,
"queue_msgs_current": 21,
"queue_nack_msgs": 0,
"queue_producers_count": 0,
"queue_push_bytes": 0,
"queue_push_msgs": 0,
"queue_ack_time_avg": 0,
"queue_put_bytes": 0,
"queue_put_msgs": 0,
}
},
"foo": {
"values": {
"queue_confirm_time_max": GreaterThan(0),
"queue_confirm_time_avg": GreaterThan(0),
"queue_nack_msgs": 0,
"queue_ack_time_max": 0,
"queue_ack_msgs": 0,
"queue_ack_time_avg": 0,
"queue_ack_time_max": 0,
"queue_bytes_current": 0,
"queue_confirm_msgs": 0,
"queue_push_bytes": 0,
"queue_confirm_time_avg": GreaterThan(0),
"queue_confirm_time_max": GreaterThan(0),
"queue_consumers_count": 0,
"queue_msgs_current": 0,
"queue_nack_msgs": 0,
"queue_producers_count": 0,
"queue_push_bytes": 0,
"queue_push_msgs": 0,
"queue_ack_time_avg": 0,
"queue_put_bytes": 0,
"queue_put_msgs": 0,
}
},
},
"values": {
"queue_confirm_time_max": GreaterThan(0),
"queue_confirm_time_avg": GreaterThan(0),
"queue_nack_msgs": 0,
"queue_ack_time_max": GreaterThan(0),
"queue_ack_msgs": 32,
"queue_ack_time_avg": GreaterThan(0),
"queue_ack_time_max": GreaterThan(0),
"queue_bytes_current": 63,
"queue_confirm_msgs": 65,
"queue_push_bytes": 288,
"queue_confirm_time_avg": GreaterThan(0),
"queue_confirm_time_max": GreaterThan(0),
"queue_consumers_count": 3,
"queue_msgs_current": 21,
"queue_nack_msgs": 0,
"queue_producers_count": 0,
"queue_push_bytes": 288,
"queue_push_msgs": 96,
"queue_ack_time_avg": GreaterThan(0),
"queue_put_bytes": 96,
"queue_put_msgs": 32,
},
Expand Down

0 comments on commit 90a7c9e

Please sign in to comment.