|
|
@@ -336,6 +336,7 @@ metric_meta(<<"emqx_vm_total_memory">>) -> ?meta(0, 1, 1);
|
|
|
metric_meta(<<"emqx_vm_used_memory">>) -> ?meta(0, 1, 1);
|
|
|
metric_meta(<<"emqx_cluster_nodes_running">>) -> ?meta(0, 1, 1);
|
|
|
metric_meta(<<"emqx_cluster_nodes_stopped">>) -> ?meta(0, 1, 1);
|
|
|
+metric_meta(<<"emqx_cluster_rpc_txid">>) -> ?meta(0, 1, 1);
|
|
|
%% END
|
|
|
metric_meta(<<"emqx_cert_expiry_at">>) -> ?meta(2, 2, 2);
|
|
|
metric_meta(<<"emqx_license_expiry_at">>) -> ?meta(0, 0, 0);
|
|
|
@@ -641,7 +642,17 @@ assert_json_data__certs(Ms, _) ->
|
|
|
Ms
|
|
|
).
|
|
|
|
|
|
-assert_json_data__cluster_rpc(Ms, _Mode) ->
|
|
|
+assert_json_data__cluster_rpc(Ms, Mode) when
|
|
|
+ Mode =:= ?PROM_DATA_MODE__NODE;
|
|
|
+ Mode =:= ?PROM_DATA_MODE__ALL_NODES_AGGREGATED
|
|
|
+->
|
|
|
+ ?assertMatch(
|
|
|
+ #{
|
|
|
+ emqx_cluster_rpc_txid := _
|
|
|
+ },
|
|
|
+ Ms
|
|
|
+ );
|
|
|
+assert_json_data__cluster_rpc(Ms, ?PROM_DATA_MODE__ALL_NODES_UNAGGREGATED) ->
|
|
|
lists:foreach(
|
|
|
fun(M) ->
|
|
|
?assertMatch(
|