/
folsom_metrics_history.erl
76 lines (62 loc) · 2.22 KB
/
folsom_metrics_history.erl
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
68
69
70
71
72
73
74
75
76
%%%
%%% Copyright 2011, Boundary
%%%
%%% Licensed under the Apache License, Version 2.0 (the "License");
%%% you may not use this file except in compliance with the License.
%%% You may obtain a copy of the License at
%%%
%%% http://www.apache.org/licenses/LICENSE-2.0
%%%
%%% Unless required by applicable law or agreed to in writing, software
%%% distributed under the License is distributed on an "AS IS" BASIS,
%%% WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
%%% See the License for the specific language governing permissions and
%%% limitations under the License.
%%%
%%%-------------------------------------------------------------------
%%% File: folsom_metrics_history.erl
%%% @author joe williams <j@boundary.com>
%%% @doc
%%% @end
%%%------------------------------------------------------------------
-module(folsom_metrics_history).
-export([new/1,
update/3,
get_events/1,
get_events/2
]).
-include("folsom.hrl").
-define(ETSOPTS, [
named_table,
ordered_set,
public
]).
new(Name) ->
ets:new(Name, ?ETSOPTS).
update(Name, Size, Value) ->
Key = folsom_utils:now_epoch_micro(),
insert(Name, Key, Size, Value, ets:info(Name, size)).
get_events(Name) ->
get_events(Name, ?DEFAULT_LIMIT).
get_events(Name, Count) ->
get_last_events(Name, Count).
% Internal API
insert(Name, Key, Size, Value, Count) when is_list(Value) ->
insert(Name, Key, Size, list_to_binary(Value), Count);
insert(Name, Key, Size, Value, Count) when Count < Size ->
true = ets:insert(Name, {Key, [{event, Value}]});
insert(Name, Key, _, Value, _) ->
FirstKey = ets:first(Name),
true = ets:delete(Name, FirstKey),
true = ets:insert(Name, {Key, [{event, Value}]}).
get_last_events(Name, Count) ->
LastKey = ets:last(Name),
get_prev_event(Name, LastKey, Count, []).
% get_prev_event/4 used by get_last_events/2
get_prev_event(_, '$end_of_table', _, Acc) ->
Acc;
get_prev_event(Name, Key, Count, Acc) when length(Acc) < Count ->
Event = ets:lookup(Name, Key),
get_prev_event(Name, ets:prev(Name, Key), Count, lists:append(Acc, Event));
get_prev_event(_, _, _, Acc) ->
Acc.