X-Git-Url: https://git.xandkar.net/?a=blobdiff_plain;f=src%2Fbeam_stats.erl;h=b3e445e269a7c9323797aeb038bf0794281aa96a;hb=11e1cb97537476ce805262952a5c615000a6cf78;hp=e3883960257cbe9f99eee7e7d56e81af97abc991;hpb=caf75ed8160362773766c6bde005cf5f33544392;p=beam_stats.git

diff --git a/src/beam_stats.erl b/src/beam_stats.erl
index e388396..b3e445e 100644
--- a/src/beam_stats.erl
+++ b/src/beam_stats.erl
@@ -7,7 +7,7 @@
     ]).
 
 -export(
-    [ collect/0
+    [ collect/1
     ]).
 
 -define(T, #?MODULE).
@@ -15,11 +15,21 @@
 -type t() ::
     ?T{}.
 
--spec collect() ->
+-spec collect(beam_stats_delta:t()) ->
     t().
-collect() ->
+collect(DeltasServer) ->
+    { {io_bytes_in  , DeltaOfIOBytesIn}
+    , {io_bytes_out , DeltaOfIOBytesOut}
+    } = beam_stats_delta:of_io(DeltasServer),
     ?T
-    { timestamp = os:timestamp()
-    , node_id   = erlang:node()
-    , memory    = erlang:memory()
+    { timestamp        = beam_stats_source:os_timestamp()
+    , node_id          = beam_stats_source:erlang_node()
+    , memory           = beam_stats_source:erlang_memory()
+    , io_bytes_in      = DeltaOfIOBytesIn
+    , io_bytes_out     = DeltaOfIOBytesOut
+    , context_switches = beam_stats_delta:of_context_switches(DeltasServer)
+    , reductions       = beam_stats_delta:of_reductions(DeltasServer)
+    , run_queue        = beam_stats_source:erlang_statistics(run_queue)
+    , ets              = beam_stats_ets:collect()
+    , processes        = beam_stats_processes:collect()
     }.