X-Git-Url: https://git.xandkar.net/?p=beam_stats.git;a=blobdiff_plain;f=src%2Fbeam_stats_consumer_statsd.erl;h=5b2f818c81ab01417c08aa7980952943f09d24f1;hp=c23ead1376ee9b209bc9b617dba81d64996db0bd;hb=refs%2Ftags%2F0.3.0;hpb=b4e2333fc5fd9f32c8a0a39db4c6faacdbb15a91 diff --git a/src/beam_stats_consumer_statsd.erl b/src/beam_stats_consumer_statsd.erl index c23ead1..5b2f818 100644 --- a/src/beam_stats_consumer_statsd.erl +++ b/src/beam_stats_consumer_statsd.erl @@ -144,17 +144,28 @@ beam_stats_to_bins(#beam_stats , memory = Memory , io_bytes_in = IOBytesIn , io_bytes_out = IOBytesOut + , context_switches = ContextSwitches } ) -> NodeIDBin = node_id_to_bin(NodeID), Msgs1 = [ io_bytes_in_to_msg(IOBytesIn) , io_bytes_out_to_msg(IOBytesOut) + , context_switches_to_msg(ContextSwitches) | memory_to_msgs(Memory) ], Msgs2 = [statsd_msg_add_name_prefix(M, NodeIDBin) || M <- Msgs1], [statsd_msg_to_bin(M) || M <- Msgs2]. +-spec context_switches_to_msg(non_neg_integer()) -> + statsd_msg(). +context_switches_to_msg(ContextSwitches) -> + #statsd_msg + { name = <<"context_switches">> + , value = ContextSwitches + , type = gauge + }. + -spec io_bytes_in_to_msg(non_neg_integer()) -> statsd_msg(). io_bytes_in_to_msg(IOBytesIn) ->