-export(
[ of_beam_stats/1
, of_beam_stats/2
- , to_bin/1
- , path_to_bin/1
+ , to_iolist/1
+ , path_to_iolist/1
, node_id_to_bin/1
]).
++ of_processes(Processes, NodeID, Ts),
lists:map(fun path_prefix_schema_version/1, Msgs).
--spec to_bin(t()) ->
- binary().
-to_bin(
+-spec to_iolist(t()) ->
+ iolist().
+to_iolist(
?T
{ path = Path
, value = Value
, timestamp = Timestamp
}
) ->
- PathBin = path_to_bin(Path),
+ PathIOList = path_to_iolist(Path),
ValueBin = integer_to_binary(Value),
TimestampInt = timestamp_to_integer(Timestamp),
TimestampBin = integer_to_binary(TimestampInt),
- <<PathBin/binary, " ", ValueBin/binary, " ", TimestampBin/binary>>.
+ [PathIOList, <<" ">>, ValueBin, <<" ">>, TimestampBin].
--spec path_to_bin([binary()]) ->
- binary().
-path_to_bin(Path) ->
- bin_join(Path, <<".">>).
+-spec path_to_iolist([binary()]) ->
+ iolist().
+path_to_iolist(Path) ->
+ interleave(Path, <<".">>).
-spec node_id_to_bin(node()) ->
binary().
schema_version() ->
<<"beam_stats_v0">>.
--spec bin_join([binary()], binary()) ->
- binary().
-bin_join([] , <<_/binary>> ) -> <<>>;
-bin_join([<<B/binary>> | []] , <<_/binary>> ) -> B;
-bin_join([<<B/binary>> | [_|_]=Bins], <<Sep/binary>>) ->
- BinsBin = bin_join(Bins, Sep),
- <<B/binary, Sep/binary, BinsBin/binary>>.
+-spec interleave(iolist(), iodata()) ->
+ iolist().
+interleave([], _) -> [];
+interleave([X], _) -> [X];
+interleave([X|Xs], Sep) ->
+ [X, Sep | interleave(Xs, Sep)].
-spec timestamp_to_integer(erlang:timestamp()) ->
non_neg_integer().
, total_heap_size = TotalHeapSize
, stack_size = StackSize
, message_queue_len = MsgQueueLen
+ , reductions = Reductions
}=Process,
<<NodeID/binary>>,
Timestamp
, cons([N, <<"process_total_heap_size">> , OriginBin], TotalHeapSize , Ts)
, cons([N, <<"process_stack_size">> , OriginBin], StackSize , Ts)
, cons([N, <<"process_message_queue_len">> , OriginBin], MsgQueueLen , Ts)
+ , cons([N, <<"process_reductions">> , OriginBin], Reductions , Ts)
].
-spec aggregate_by_path([t()], erlang:timestamp()) ->