Packages

prometheus

4.12.0
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
1 Dependency
Dependants
Files
Activity
prometheus src prometheus_sup.erl
Raw

src/prometheus_sup.erl 

-module(prometheus_sup).

-compile({parse_transform, prometheus_pt}).

-moduledoc false.



-export([start_link/0]).

-export([init/1]).

-export([register_metrics/1]).



-behaviour(supervisor).



-include("prometheus.hrl").



-spec start_link() -> supervisor:startlink_ret().

start_link() ->

    supervisor:start_link({local, ?MODULE}, ?MODULE, []).



-spec init([]) -> {ok, {supervisor:sup_flags(), [supervisor:child_spec()]}}.

init([]) ->

    create_tables(),

    register_collectors(),

    register_metrics(),

    setup_instrumenters(),

    {ok, {{one_for_one, 5, 1}, []}}.



%%====================================================================

%% Private Parts

%%====================================================================



create_tables() ->

    Tables = [

        {?PROMETHEUS_REGISTRY_TABLE, {bag, read_concurrency}},

        {?PROMETHEUS_COUNTER_TABLE, write_concurrency},

        {?PROMETHEUS_GAUGE_TABLE, write_concurrency},

        {?PROMETHEUS_SUMMARY_TABLE, write_concurrency},

        {?PROMETHEUS_QUANTILE_SUMMARY_TABLE, write_concurrency},

        {?PROMETHEUS_HISTOGRAM_TABLE, write_concurrency},

        {?PROMETHEUS_BOOLEAN_TABLE, write_concurrency}

    ],

    [maybe_create_table(Name, Concurrency) || {Name, Concurrency} <- Tables],

    ok.



register_collectors() ->

    Collectors = prometheus_collector:enabled_collectors(),

    prometheus_registry:register_collectors(Collectors).



register_metrics() ->

    [declare_metric(Decl) || Decl <- default_metrics()].



-spec register_metrics([term()]) -> [boolean()].

register_metrics(Metrics) ->

    DefaultMetrics0 = default_metrics(),

    DefaultMetrics1 = lists:usort(DefaultMetrics0 ++ Metrics),

    application:set_env(prometheus, default_metrics, DefaultMetrics1),

    [declare_metric(Decl) || Decl <- Metrics].



setup_instrumenters() ->

    [

        prometheus_instrumenter:setup(Instrumenter)

     || Instrumenter <- prometheus_instrumenter:enabled_instrumenters()

    ].



default_metrics() ->

    application:get_env(prometheus, default_metrics, []).



maybe_create_table(Name, {Type, Concurrency}) ->

    case ets:info(Name) of

        undefined ->

            ets:new(Name, [Type, named_table, public, {Concurrency, true}]);

        _ ->

            ok

    end;

maybe_create_table(Name, Concurrency) ->

    maybe_create_table(Name, {set, Concurrency}).



declare_metric({Metric, Spec}) ->

    declare_metric(Metric, Spec);

declare_metric({Registry, Metric, Spec}) ->

    declare_metric(Metric, [{registry, Registry}] ++ Spec).



declare_metric(counter, Spec) ->

    prometheus_counter:declare(Spec);

declare_metric(gauge, Spec) ->

    prometheus_gauge:declare(Spec);

declare_metric(summary, Spec) ->

    prometheus_summary:declare(Spec);

declare_metric(histogram, Spec) ->

    prometheus_histogram:declare(Spec);

declare_metric(boolean, Spec) ->

    prometheus_boolean:declare(Spec);

declare_metric(Other, Spec) ->

    Other:declare(Spec).