fix: remove duplicated code

This commit is contained in:
EMQ-YangM 2022-04-28 16:10:47 +08:00
parent 4365de9ad5
commit 51e025f075
2 changed files with 17 additions and 20 deletions

View File

@ -115,23 +115,10 @@ fields("metrics_status_fields") ->
]; ];
fields("metrics") -> fields("metrics") ->
[ [
{"matched", mk(integer(), #{desc => ?DESC("matched")})}, {"ignore", mk(integer(), #{desc => ?DESC("failed")})}
{"success", mk(integer(), #{desc => ?DESC("success")})}, ] ++ common_field();
{"failed", mk(integer(), #{desc => ?DESC("failed")})},
{"ignore", mk(integer(), #{desc => ?DESC("failed")})},
{"rate", mk(float(), #{desc => ?DESC("rate")})},
{"rate_max", mk(float(), #{desc => ?DESC("rate_max")})},
{"rate_last5m", mk(float(), #{desc => ?DESC("rate_last5m")})}
];
fields("resource_metrics") -> fields("resource_metrics") ->
[ common_field();
{"matched", mk(integer(), #{desc => ?DESC("matched")})},
{"success", mk(integer(), #{desc => ?DESC("success")})},
{"failed", mk(integer(), #{desc => ?DESC("failed")})},
{"rate", mk(float(), #{desc => ?DESC("rate")})},
{"rate_max", mk(float(), #{desc => ?DESC("rate_max")})},
{"rate_last5m", mk(float(), #{desc => ?DESC("rate_last5m")})}
];
fields("node_metrics") -> fields("node_metrics") ->
[ [
node_name(), node_name(),
@ -153,6 +140,16 @@ fields("node_error") ->
{"error", mk(string(), #{desc => ?DESC("node_error")})} {"error", mk(string(), #{desc => ?DESC("node_error")})}
]. ].
common_field() ->
[
{"matched", mk(integer(), #{desc => ?DESC("matched")})},
{"success", mk(integer(), #{desc => ?DESC("success")})},
{"failed", mk(integer(), #{desc => ?DESC("failed")})},
{"rate", mk(float(), #{desc => ?DESC("rate")})},
{"rate_max", mk(float(), #{desc => ?DESC("rate_max")})},
{"rate_last5m", mk(float(), #{desc => ?DESC("rate_last5m")})}
].
status() -> status() ->
hoconsc:enum([connected, disconnected, connecting]). hoconsc:enum([connected, disconnected, connecting]).

View File

@ -22,14 +22,14 @@
-compile(export_all). -compile(export_all).
-define(CLUSTER_RPC_SHARD, emqx_cluster_rpc_shard). -define(CLUSTER_RPC_SHARD, emqx_cluster_rpc_shard).
-define(CONF_DEFAULT, -define(CONF_DEFAULT, <<
<<"\n" "\n"
"prometheus {\n" "prometheus {\n"
" push_gateway_server = \"http://127.0.0.1:9091\"\n" " push_gateway_server = \"http://127.0.0.1:9091\"\n"
" interval = \"1s\"\n" " interval = \"1s\"\n"
" enable = true\n" " enable = true\n"
"}\n">> "}\n"
). >>).
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------
%% Setups %% Setups