yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat(prometheus): license expiry at epoch as gauge

This commit is contained in:
JimMoen 2024-01-11 22:27:55 +08:00
parent fae0cea17f
commit 558c471392
No known key found for this signature in database
1 changed files with 19 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
apps/emqx_prometheus/src/emqx_prometheus.erl
View File

@ -173,7 +173,9 @@ collect_mf(_Registry, Callback) ->
Metrics = emqx_metrics:all(), Metrics = emqx_metrics:all(),
Stats = emqx_stats:getstats(), Stats = emqx_stats:getstats(),
VMData = emqx_vm_data(), VMData = emqx_vm_data(),
LicenseData = emqx_license_data(),
ClusterData = emqx_cluster_data(), ClusterData = emqx_cluster_data(),
_ = [add_collect_family(Name, LicenseData, Callback, gauge) || Name <- emqx_license()],
_ = [add_collect_family(Name, Stats, Callback, gauge) || Name <- emqx_stats:names()], _ = [add_collect_family(Name, Stats, Callback, gauge) || Name <- emqx_stats:names()],
_ = [add_collect_family(Name, VMData, Callback, gauge) || Name <- emqx_vm()], _ = [add_collect_family(Name, VMData, Callback, gauge) || Name <- emqx_vm()],
_ = [add_collect_family(Name, ClusterData, Callback, gauge) || Name <- emqx_cluster()], _ = [add_collect_family(Name, ClusterData, Callback, gauge) || Name <- emqx_cluster()],
@ -192,7 +194,9 @@ collect(<<"json">>) ->
Metrics = emqx_metrics:all(), Metrics = emqx_metrics:all(),
Stats = emqx_stats:getstats(), Stats = emqx_stats:getstats(),
VMData = emqx_vm_data(), VMData = emqx_vm_data(),
LicenseData = emqx_license_data(),
#{ #{
license => maps:from_list([collect_stats(Name, LicenseData) || Name <- emqx_license()]),
stats => maps:from_list([collect_stats(Name, Stats) || Name <- emqx_stats:names()]), stats => maps:from_list([collect_stats(Name, Stats) || Name <- emqx_stats:names()]),
metrics => maps:from_list([collect_stats(Name, VMData) || Name <- emqx_vm()]), metrics => maps:from_list([collect_stats(Name, VMData) || Name <- emqx_vm()]),
packets => maps:from_list([collect_stats(Name, Metrics) || Name <- emqx_metrics_packets()]), packets => maps:from_list([collect_stats(Name, Metrics) || Name <- emqx_metrics_packets()]),
@ -506,7 +510,6 @@ emqx_collect(emqx_authentication_failure, Stats) ->
counter_metric(?C('authentication.failure', Stats)); counter_metric(?C('authentication.failure', Stats));
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------
%% VM %% VM
emqx_collect(emqx_vm_cpu_use, VMData) -> emqx_collect(emqx_vm_cpu_use, VMData) ->
gauge_metric(?C(cpu_use, VMData)); gauge_metric(?C(cpu_use, VMData));
emqx_collect(emqx_vm_cpu_idle, VMData) -> emqx_collect(emqx_vm_cpu_idle, VMData) ->
@ -522,7 +525,11 @@ emqx_collect(emqx_vm_used_memory, VMData) ->
emqx_collect(emqx_cluster_nodes_running, ClusterData) -> emqx_collect(emqx_cluster_nodes_running, ClusterData) ->
gauge_metric(?C(nodes_running, ClusterData)); gauge_metric(?C(nodes_running, ClusterData));
emqx_collect(emqx_cluster_nodes_stopped, ClusterData) -> emqx_collect(emqx_cluster_nodes_stopped, ClusterData) ->
gauge_metric(?C(nodes_stopped, ClusterData)). gauge_metric(?C(nodes_stopped, ClusterData));
%%--------------------------------------------------------------------
%% License
emqx_collect(emqx_license_expiry_at, LicenseData) ->
gauge_metric(?C(expiry_at, LicenseData)).
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------
%% Indicators %% Indicators
@ -687,6 +694,16 @@ emqx_cluster_data() ->
{nodes_stopped, length(Stopped)} {nodes_stopped, length(Stopped)}
]. ].
emqx_license() ->
[
emqx_license_expiry_at
].
emqx_license_data() ->
[
{expiry_at, emqx_license_checker:expiry_epoch()}
].
%% deprecated_since 5.0.10, remove this when 5.1.x %% deprecated_since 5.0.10, remove this when 5.1.x
do_start() -> do_start() ->
emqx_prometheus_sup:start_child(?APP). emqx_prometheus_sup:start_child(?APP).