1 -module(beam_stats_consumer_statsd_SUITE).
3 -include_lib("beam_stats/include/beam_stats.hrl").
4 -include_lib("beam_stats/include/beam_stats_ets_table.hrl").
16 -define(GROUP, beam_stats_consumer_statsd).
18 %% ============================================================================
19 %% Common Test callbacks
20 %% ============================================================================
30 [{?GROUP, Properties, Tests}].
32 %% =============================================================================
34 %% =============================================================================
51 % TODO: Indent #beam_stats as #beam_stats_ets_table
52 BEAMStats = #beam_stats
53 { timestamp = {1, 2, 3}
54 , node_id = 'node_foo@host_bar'
55 , memory = [{mem_type_foo, 1}]
58 , context_switches = 5
61 , ets = [ETSTableStatsFoo, ETSTableStatsBar]
64 {ok, ServerSocket} = gen_udp:open(ServerPort, [binary, {active, false}]),
65 BEAMStatsQ = queue:in(BEAMStats, queue:new()),
66 Options = [{dst_port, ServerPort}],
67 {_, State1} = beam_stats_consumer_statsd:init(Options),
68 State2 = beam_stats_consumer_statsd:consume(BEAMStatsQ, State1),
69 {} = beam_stats_consumer_statsd:terminate(State2),
70 ResultOfReceive = gen_udp:recv(ServerSocket, 0),
71 ok = gen_udp:close(ServerSocket),
72 {ok, {_, _, Data}} = ResultOfReceive,
73 ct:log("Packet: ~n~s~n", [Data]),
74 << "beam_stats.node_foo_host_bar.io.bytes_in:3|g\n"
75 , "beam_stats.node_foo_host_bar.io.bytes_out:7|g\n"
76 , "beam_stats.node_foo_host_bar.context_switches:5|g\n"
77 , "beam_stats.node_foo_host_bar.reductions:9|g\n"
78 , "beam_stats.node_foo_host_bar.run_queue:17|g\n"
79 , "beam_stats.node_foo_host_bar.memory.mem_type_foo:1|g\n"
80 , "beam_stats.node_foo_host_bar.ets_table.size.foo.foo:5|g\n"
81 , "beam_stats.node_foo_host_bar.ets_table.memory.foo.foo:25|g\n"
82 , "beam_stats.node_foo_host_bar.ets_table.size.bar.37:8|g\n"
83 , "beam_stats.node_foo_host_bar.ets_table.memory.bar.37:38|g\n"