X-Git-Url: https://git.xandkar.net/?p=beam_stats.git;a=blobdiff_plain;f=src%2Fbeam_stats_consumer_graphite.erl;fp=src%2Fbeam_stats_consumer_graphite.erl;h=9f13a6653549d86ab353b470dd70119d6c2c7c9a;hp=512247995601d0c93dc2b905b6663ca6354ac7d2;hb=cdcb989e330d3a018b44b154c190c33b9b27040c;hpb=7c381eb2b650aa0219b8c489dfc2a377f92a2a52 diff --git a/src/beam_stats_consumer_graphite.erl b/src/beam_stats_consumer_graphite.erl index 5122479..9f13a66 100644 --- a/src/beam_stats_consumer_graphite.erl +++ b/src/beam_stats_consumer_graphite.erl @@ -52,7 +52,7 @@ init(Options) -> -spec consume(beam_stats_consumer:queue(), state()) -> state(). consume(Q, #state{}=State1) -> - Payload = beam_stats_queue_to_binary(Q), + Payload = beam_stats_queue_to_iolists(Q), State2 = try_to_connect_if_no_socket(State1), try_to_send(State2, Payload). @@ -64,7 +64,7 @@ terminate(#state{sock=SockOpt}) -> %% ============================================================================ --spec try_to_send(state(), binary()) -> +-spec try_to_send(state(), iolist()) -> state(). try_to_send(#state{sock=none}=State, _) -> ?log_error("Sending failed. No socket in state."), @@ -105,14 +105,13 @@ try_to_connect_if_no_socket( State#state{sock = none} end. --spec beam_stats_queue_to_binary(beam_stats_consumer:queue()) -> - binary(). -beam_stats_queue_to_binary(Q) -> - Bins = [beam_stats_to_bins(B) || B <- queue:to_list(Q)], - iolist_to_binary(Bins). +-spec beam_stats_queue_to_iolists(beam_stats_consumer:queue()) -> + [iolist()]. +beam_stats_queue_to_iolists(Q) -> + [beam_stats_to_iolist(B) || B <- queue:to_list(Q)]. --spec beam_stats_to_bins(beam_stats:t()) -> - [binary()]. -beam_stats_to_bins(#beam_stats{}=BeamStats) -> +-spec beam_stats_to_iolist(beam_stats:t()) -> + [iolist()]. +beam_stats_to_iolist(#beam_stats{}=BeamStats) -> Msgs = beam_stats_msg_graphite:of_beam_stats(BeamStats), - lists:map(fun beam_stats_msg_graphite:to_bin/1, Msgs). + lists:map(fun beam_stats_msg_graphite:to_iolist/1, Msgs).