Packages

prometheus

0.1.2
6.1.3 6.1.2 6.1.1 6.1.0 6.0.3 6.0.2 6.0.1 6.0.0 5.1.1 5.1.0 5.0.0 4.13.0 retired 4.12.0 4.11.0 4.10.0 4.9.1 4.9.0 4.8.2 4.8.1 4.8.0 4.6.0 4.5.0 4.4.1 4.4.0 4.3.0 4.2.2 4.2.0 4.1.0 4.0.1 4.0.0 3.5.1 3.5.0 3.4.6 3.4.5 3.4.4 3.4.3 3.4.2 3.4.1 3.4.0 3.3.2 3.3.1 3.3.0 3.2.3 3.2.2 3.2.1 3.1.1 3.1.0 3.0.1 3.0.0 3.0.0-rc1 3.0.0-alpha9 3.0.0-alpha8 3.0.0-alpha7 3.0.0-alpha6 3.0.0-alpha5 3.0.0-alpha4 3.0.0-alpha3 3.0.0-alpha2 3.0.0-alpha10 3.0.0-alpha1 2.2.0 2.1.0 2.0.0 1.7.0 1.6.0 1.5.0 1.0.2 1.0.1 1.0.0 0.2.0 0.1.3 0.1.2 0.1.1 0.1.0

Prometheus.io client in Erlang

HexDocs

Current section

Files

Jump to
Readme
74 Versions
0 Dependencies
Dependants
Files
Activity
prometheus src collectors vm prometheus_vm_memory_collector.erl
Raw

src/collectors/vm/prometheus_vm_memory_collector.erl 

-module(prometheus_vm_memory_collector).

-export([register/0,

         register/1,

         deregister/1,

         collect_mf/2,

         collect_metrics/3]).



-behaviour(prometheus_collector).

-include("prometheus.hrl").



register() ->

  register(default).



register(Registry) ->

  ok = prometheus_registry:register_collector(Registry, ?MODULE).



deregister(_) -> ok.



collect_mf(Callback, _Registry) ->

  Memory = erlang:memory(),

  Callback(gauge, erlang_vm_memory_bytes_total, [kind], "The total amount of memory currently allocated. This is the same as the sum of the memory size for processes and system.", Memory),

  Callback(gauge, erlang_vm_memory_processes_bytes_total, [usage], "The total amount of memory currently allocated for the Erlang processes.", Memory),

  Callback(gauge, erlang_vm_memory_system_bytes_total, [usage], "The total amount of memory currently allocated for the emulator that is not directly related to ay Erlang process. Memory presented as processes is not included in this memory.", Memory),

  Callback(gauge, erlang_vm_memory_atom_bytes_total, [usage], "The total amount of memory currently allocated for atoms. This memory is part of the memory presented as system memory.", Memory),

  Callback(gauge, erlang_vm_ets_tables, [], "Erlang VM ETS Tables count", []),

  Callback(gauge, erlang_vm_dets_tables, [], "Erlang VM DETS Tables count", []).



collect_metrics(erlang_vm_memory_bytes_total, Callback, Memory) ->

  Callback([system], proplists:get_value(system, Memory)),

  Callback([processes], proplists:get_value(processes, Memory));

collect_metrics(erlang_vm_memory_processes_bytes_total, Callback, Memory) ->

  Callback([used], proplists:get_value(processes_used, Memory)),

  Callback([free], proplists:get_value(processes, Memory) - proplists:get_value(processes_used, Memory));

collect_metrics(erlang_vm_memory_system_bytes_total, Callback, Memory) ->

  Callback([atom], proplists:get_value(atom, Memory)),

  Callback([binary], proplists:get_value(binary, Memory)),

  Callback([code], proplists:get_value(code, Memory)),

  Callback([ets], proplists:get_value(ets, Memory)),

  Callback([other], proplists:get_value(system, Memory) - proplists:get_value(atom, Memory)

           - proplists:get_value(binary, Memory) - proplists:get_value(code, Memory) - proplists:get_value(ets, Memory));

collect_metrics(erlang_vm_memory_atom_bytes_total, Callback, Memory) ->

  Callback([used], proplists:get_value(atom_used, Memory)),

  Callback([free], proplists:get_value(atom, Memory) - proplists:get_value(atom_used, Memory));

collect_metrics(erlang_vm_ets_tables, Callback, _MFData) ->

  Callback([], length(ets:all()));

collect_metrics(erlang_vm_dets_tables, Callback, _MFData) ->

  Callback([], length(dets:all())).