home
/
code
/
beam_stats.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge pull request #20 from ibnfirnas/per-process-reductions
[beam_stats.git]
/
src
/
beam_stats_consumer_statsd.erl
diff --git
a/src/beam_stats_consumer_statsd.erl
b/src/beam_stats_consumer_statsd.erl
index
06945e1
..
644fb63
100644
(file)
--- a/
src/beam_stats_consumer_statsd.erl
+++ b/
src/beam_stats_consumer_statsd.erl
@@
-41,8
+41,6
@@
-type state() ::
#state{}.
-type state() ::
#state{}.
--define(PATH_PREFIX, <<"beam_stats">>).
-
%% ============================================================================
%% Consumer implementation
%% ============================================================================
%% ============================================================================
%% Consumer implementation
%% ============================================================================
@@
-154,10
+152,7
@@
beam_stats_queue_to_packets(Q, NumMsgsPerPacket, StaticNodeNameOpt) ->
beam_stats_to_bins(#beam_stats{node_id=NodeID}=BeamStats, StaticNodeNameOpt) ->
NodeIDBinDefault = beam_stats_msg_graphite:node_id_to_bin(NodeID),
NodeIDBin = hope_option:get(StaticNodeNameOpt, NodeIDBinDefault),
beam_stats_to_bins(#beam_stats{node_id=NodeID}=BeamStats, StaticNodeNameOpt) ->
NodeIDBinDefault = beam_stats_msg_graphite:node_id_to_bin(NodeID),
NodeIDBin = hope_option:get(StaticNodeNameOpt, NodeIDBinDefault),
- GraphiteMsgAddPrefix =
- fun (M) -> beam_stats_msg_graphite:add_path_prefix(M, ?PATH_PREFIX) end,
- MsgsGraphite1 = beam_stats_msg_graphite:of_beam_stats(BeamStats, NodeIDBin),
- MsgsGraphite2 = lists:map(GraphiteMsgAddPrefix, MsgsGraphite1),
+ MsgsGraphite = beam_stats_msg_graphite:of_beam_stats(BeamStats, NodeIDBin),
MsgsStatsD =
MsgsStatsD =
- lists:map(fun beam_stats_msg_statsd_gauge:of_msg_graphite/1, MsgsGraphite
2
),
+ lists:map(fun beam_stats_msg_statsd_gauge:of_msg_graphite/1, MsgsGraphite),
lists:map(fun beam_stats_msg_statsd_gauge:to_bin/1, MsgsStatsD).
lists:map(fun beam_stats_msg_statsd_gauge:to_bin/1, MsgsStatsD).
This page took
0.02421 seconds
and
4
git commands to generate.