Skip to content

Commit

Permalink
It: Extend admin it for history size stat
Browse files Browse the repository at this point in the history
  • Loading branch information
@chrisbeard
chrisbeard committed Oct 9, 2024
1 parent 1470580 commit 04876ed
Show file tree
Hide file tree
Showing 2 changed files with 14 additions and 0 deletions.
2 changes: 2 additions & 0 deletions src/groups/mqb/mqbstat/mqbstat_jsonprinter.cpp
View file
Original file line number Diff line number Diff line change
Expand Up @@ -119,6 +119,8 @@ struct ConversionUtils {

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

populateMetric(&values, ctx, Stat::e_HISTORY_ABS);
}

inline static void populateOneDomainStats(bdljsn::JsonObject* domainObject,
Expand Down
12 changes: 12 additions & 0 deletions src/python/blazingmq/dev/it/data/data_metrics.py
View file
Original file line number Diff line number Diff line change
Expand Up @@ -71,6 +71,7 @@ def check(self, value: Any) -> bool:
"queue_content_msgs": 32,
"queue_gc_msgs": 0,
"queue_gc_msgs_abs": 0,
"queue_history_abs": 0,
"queue_msgs_current": 32,
"queue_nack_msgs": 0,
"queue_nack_msgs_abs": 0,
Expand Down Expand Up @@ -110,6 +111,7 @@ def check(self, value: Any) -> bool:
"queue_content_msgs": 32,
"queue_gc_msgs": 0,
"queue_gc_msgs_abs": 0,
"queue_history_abs": 0,
"queue_msgs_current": 32,
"queue_nack_msgs": 0,
"queue_nack_msgs_abs": 0,
Expand Down Expand Up @@ -149,6 +151,7 @@ def check(self, value: Any) -> bool:
"queue_content_msgs": 32,
"queue_gc_msgs": 0,
"queue_gc_msgs_abs": 0,
"queue_history_abs": 0,
"queue_msgs_current": 32,
"queue_nack_msgs": 0,
"queue_nack_msgs_abs": 0,
Expand Down Expand Up @@ -188,6 +191,7 @@ def check(self, value: Any) -> bool:
"queue_content_msgs": 32,
"queue_gc_msgs": 0,
"queue_gc_msgs_abs": 0,
"queue_history_abs": 0,
"queue_msgs_current": 32,
"queue_nack_msgs": 0,
"queue_nack_msgs_abs": 0,
Expand Down Expand Up @@ -230,6 +234,7 @@ def check(self, value: Any) -> bool:
"queue_content_msgs": 32,
"queue_gc_msgs": 0,
"queue_gc_msgs_abs": 0,
"queue_history_abs": 0,
"queue_msgs_current": 10,
"queue_nack_msgs": 0,
"queue_nack_msgs_abs": 0,
Expand Down Expand Up @@ -269,6 +274,7 @@ def check(self, value: Any) -> bool:
"queue_content_msgs": 32,
"queue_gc_msgs": 0,
"queue_gc_msgs_abs": 0,
"queue_history_abs": 0,
"queue_msgs_current": 21,
"queue_nack_msgs": 0,
"queue_nack_msgs_abs": 0,
Expand Down Expand Up @@ -308,6 +314,7 @@ def check(self, value: Any) -> bool:
"queue_content_msgs": 32,
"queue_gc_msgs": 0,
"queue_gc_msgs_abs": 0,
"queue_history_abs": 0,
"queue_msgs_current": 0,
"queue_nack_msgs": 0,
"queue_nack_msgs_abs": 0,
Expand Down Expand Up @@ -347,6 +354,7 @@ def check(self, value: Any) -> bool:
"queue_content_msgs": 32,
"queue_gc_msgs": 0,
"queue_gc_msgs_abs": 0,
"queue_history_abs": 11,
"queue_msgs_current": 21,
"queue_nack_msgs": 0,
"queue_nack_msgs_abs": 0,
Expand Down Expand Up @@ -389,6 +397,7 @@ def check(self, value: Any) -> bool:
"queue_content_msgs": 32,
"queue_gc_msgs": 0,
"queue_gc_msgs_abs": 0,
"queue_history_abs": 0,
"queue_msgs_current": 10,
"queue_nack_msgs": 0,
"queue_nack_msgs_abs": 0,
Expand Down Expand Up @@ -428,6 +437,7 @@ def check(self, value: Any) -> bool:
"queue_content_msgs": 32,
"queue_gc_msgs": 0,
"queue_gc_msgs_abs": 0,
"queue_history_abs": 0,
"queue_msgs_current": 0,
"queue_nack_msgs": 0,
"queue_nack_msgs_abs": 0,
Expand Down Expand Up @@ -467,6 +477,7 @@ def check(self, value: Any) -> bool:
"queue_content_msgs": 32,
"queue_gc_msgs": 0,
"queue_gc_msgs_abs": 0,
"queue_history_abs": 0,
"queue_msgs_current": 0,
"queue_nack_msgs": 0,
"queue_nack_msgs_abs": 0,
Expand Down Expand Up @@ -506,6 +517,7 @@ def check(self, value: Any) -> bool:
"queue_content_msgs": 32,
"queue_gc_msgs": 0,
"queue_gc_msgs_abs": 0,
"queue_history_abs": 22,
"queue_msgs_current": 10,
"queue_nack_msgs": 0,
"queue_nack_msgs_abs": 0,
Expand Down

0 comments on commit 04876ed

Please sign in to comment.