Packages

wolff

2.0.0
4.2.1 4.2.0 4.1.11 4.1.10 4.1.9 4.1.8 4.1.7 4.1.6 4.1.5 4.1.4 4.1.3 4.1.2 4.1.1 4.1.0 4.0.13 4.0.12 4.0.11 4.0.10 4.0.9 4.0.8 4.0.7 4.0.6 4.0.5 4.0.4 4.0.3 4.0.2 4.0.1 4.0.0 3.0.4 3.0.3 2.0.0 1.10.4 1.10.2 1.10.1 1.10.0 1.9.1 1.7.7 1.7.6 1.7.4 1.7.1 1.6.4 1.6.1 1.6.0

Kafka's publisher

Current section

Files

Jump to
Readme
43 Versions
4 Dependencies
Dependants
Files
Activity
wolff src wolff_metrics.erl
Raw

src/wolff_metrics.erl 

-module(wolff_metrics).





-export([

    inflight_set/2,

    queuing_set/2,

    dropped_inc/1,

    dropped_inc/2,

    dropped_queue_full_inc/1,

    dropped_queue_full_inc/2,

    failed_inc/1,

    failed_inc/2,

    retried_inc/1,

    retried_inc/2,

    retried_failed_inc/1,

    retried_failed_inc/2,

    retried_success_inc/1,

    retried_success_inc/2,

    success_inc/1,

    success_inc/2

]).



%% Gauges (value can go both up and down):

%% --------------------------------------



%% @doc Count of requests (batches of messages) that are currently queuing. [Gauge]

queuing_set(Config, Val) ->

    telemetry:execute([wolff, queuing],

                      #{gauge_set => Val},

                      telemetry_meta_data(Config)).



%% @doc Count of messages that were sent asynchronously but ACKs are not

%% received. [Gauge]

inflight_set(Config, Val) ->

    telemetry:execute([wolff, inflight],

                      #{gauge_set => Val},

                      telemetry_meta_data(Config)).



%% Counters (value can only got up):

%% --------------------------------------



%% @doc Count of messages dropped

dropped_inc(Config) ->

    dropped_inc(Config, 1).



dropped_inc(Config, Val) ->

    telemetry:execute([wolff, dropped],

                      #{counter_inc => Val},

                      telemetry_meta_data(Config)).



%% @doc Count of messages dropped because the queue was full

dropped_queue_full_inc(Config) ->

    dropped_queue_full_inc(Config, 1).



dropped_queue_full_inc(Config, Val) ->

    telemetry:execute([wolff, dropped_queue_full],

                      #{counter_inc => Val},

                      telemetry_meta_data(Config)).



%% @doc The number of times message sends have been retried

retried_inc(Config) ->

    retried_inc(Config, 1).



retried_inc(Config, Val) ->

    telemetry:execute([wolff, retried],

                      #{counter_inc => Val},

                      telemetry_meta_data(Config)).



%% @doc Count of message sends that have failed

failed_inc(Config) ->

    failed_inc(Config, 1).



failed_inc(Config, Val) ->

    telemetry:execute([wolff, failed],

                      #{counter_inc => Val},

                      telemetry_meta_data(Config)).



%%% @doc Count of message sends that have failed after having been retried

retried_failed_inc(Config) ->

    retried_failed_inc(Config, 1).



retried_failed_inc(Config, Val) ->

    telemetry:execute([wolff, retried_failed],

                      #{counter_inc => Val},

                      telemetry_meta_data(Config)).



 %% @doc Count messages that were sucessfully sent after at least one retry

retried_success_inc(Config) ->

     retried_success_inc(Config, 1).



retried_success_inc(Config, Val) ->

     telemetry:execute([wolff, retried_success],

                       #{counter_inc => Val},

                       telemetry_meta_data(Config)).



%% @doc Count of messages that have been sent successfully

success_inc(Config) ->

    success_inc(Config, 1).



success_inc(Config, Val) ->

    telemetry:execute([wolff, success],

                      #{counter_inc => Val},

                      telemetry_meta_data(Config)).



telemetry_meta_data(Config) ->

    maps:get(telemetry_meta_data, Config, #{}).