Packages
prometheus
0.2.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
Current section
Files
Jump to
Current section
Files
src/formats/prometheus_text_format.erl
-module(prometheus_text_format).
-export([content_type/0,
format/0,
format/1,
registry_collect_callback/3,
collector_metrics_callback/5]).
-ifdef(TEST).
-export([escape_metric_help/1,
escape_label_value/1]).
-endif.
-include("prometheus.hrl").
-behaviour(prometheus_format).
content_type() ->
<<"text/plain; version=0.0.4">>.
format() ->
format(default).
format(Registry) ->
{ok, Fd} = ram_file:open("", [write,read,binary]),
prometheus_registry:collect(Registry, fun (_, Collector) ->
registry_collect_callback(Fd, Registry, Collector)
end),
file:write(Fd, io_lib:format("\n", [])),
{ok, Size} = ram_file:get_size(Fd),
{ok, Str} = file:pread(Fd, 0, Size),
ok = file:close(Fd),
Str.
emit_mf_prologue(Fd, Type, Name, Help) ->
file:write(Fd, io_lib:format("# TYPE ~s ~s\n# HELP ~s ~s\n", [Name, Type, Name, escape_metric_help(Help)])).
registry_collect_callback(Fd, Registry, Collector) ->
Collector:collect_mf(
fun (Type, MFName, Labels, Help, MFData) ->
emit_mf_prologue(Fd, Type, MFName, Help),
Collector:collect_metrics(MFName,
fun (Series, Value) ->
case Series of
{Name, LabelValues} ->
collector_metrics_callback(Fd, Name, Labels, LabelValues, Value);
{Name, NewLabels, LabelValues} ->
collector_metrics_callback(Fd, Name, Labels ++ NewLabels, LabelValues, Value);
LabelValues ->
collector_metrics_callback(Fd, MFName, Labels, LabelValues, Value)
end
end,
MFData)
end,
Registry).
labels_string(Labels, LabelValues) ->
case length(Labels) of
0 ->
"";
_ ->
LabelsPList = lists:zip(Labels, LabelValues),
"{" ++ string:join(lists:map(fun ({Label, Value1}) ->
io_lib:format("~s=\"~s\"", [Label, escape_label_value(Value1)])
end,
LabelsPList),
",") ++ "}"
end.
collector_metrics_callback(Fd, Name, Labels, LabelValues, '') ->
LString = labels_string(Labels, LabelValues),
file:write(Fd, io_lib:format("~s" ++ LString ++ " NaN\n", [Name]));
collector_metrics_callback(Fd, Name, Labels, LabelValues, undefined) ->
LString = labels_string(Labels, LabelValues),
file:write(Fd, io_lib:format("~s" ++ LString ++ " NaN\n", [Name]));
collector_metrics_callback(Fd, Name, Labels, LabelValues, Value) ->
LString = labels_string(Labels, LabelValues),
file:write(Fd, io_lib:format("~s" ++ LString ++ " ~p\n", [Name, Value])).
escape_metric_help(Help) ->
sub(sub(Help, "\\", "\\\\\\\\"), "\n", "\\\\n").
escape_label_value(LValue) when is_list(LValue)->
sub(sub(sub(LValue, "\\", "\\\\\\\\"), "\n", "\\\\n"), "\"", "\\\\\"");
escape_label_value(LValue) when is_binary(LValue) ->
escape_label_value(binary_to_list(LValue));
escape_label_value('+Inf') ->
"+Inf";
escape_label_value(LValue) ->
escape_label_value(io_lib:format("~p", [LValue])).
sub(Str, Old, New) when is_atom(Str) ->
sub(atom_to_list(Str), Old, New);
sub(Str,Old,New) ->
RegExp = "\\Q"++Old++"\\E",
re:replace(Str,RegExp,New,[global, {return, list}]).