1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
|
%% Copyright (c) 2016-2018, Benoit Chesneau.
%%
%% This file is part of erlang-metrics released under the BSD license.
%% See the NOTICE for more information.
%%
%% @doc exometer backend
-module(metrics_exometer).
-author("Benoit Chesneau").
%% API
-export([new/3, update/3, update_or_create/4, delete/2]).
-spec new(atom(), any(), map()) -> ok | {error, metric_exists | unsupported_type}.
new(counter, Name, _Config) ->
ensure(Name, counter);
new(histogram, Name, _Config) ->
ensure(Name, histogram);
new(gauge, Name, _Config) ->
ensure(Name, gauge);
new(meter, Name, _Config) ->
ensure(Name, meter);
new(spiral, Name, _Config) ->
ensure(Name, spiral);
new(duration, Name, _Config) ->
ensure(Name, duration);
new(_, _, _) ->
{error, unsupported_type}.
ensure(Name, Type) ->
M = module(),
M:ensure(Name, Type, []).
update(Name, {c, I}, _Config) when is_integer(I) -> update(Name, I);
update(Name, {duration_fun, Fun}, _Config) when is_function(Fun) ->
update(Name, timer_start),
try Fun()
after update(Name, timer_end)
end;
update(Name, Val, _Config) -> update(Name, Val).
update(Name, Val) ->
M = module(),
M:update(Name, Val).
update_or_create(Name, {c, I}, Type, _Config) when is_integer(I) ->
update_or_create(Name, I, Type);
update_or_create(Name, {duration_fun, Fun}, Type, Config) when is_function(Fun) ->
_ = ensure(Name, Type),
update_or_create(Name, {duration_fun, Fun}, Config);
update_or_create(Name, Val, Type, _Config) ->
update_or_create(Name, Val, Type).
update_or_create(Name, Val, Type) ->
M = module(),
M:update_or_create(Name, Val, Type, []).
delete(Name, _Config) ->
M = module(),
M:delete(Name).
module() -> exometer.
|
