yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

chore(telemetry): Add an RLOG shard

This commit is contained in:
k32 2021-06-28 18:14:36 +02:00
parent 26b2216e25
commit 1618a90ddd
1 changed files with 11 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
apps/emqx_telemetry/src/emqx_telemetry.erl
View File

@ -90,6 +90,8 @@
-define(TELEMETRY, emqx_telemetry). -define(TELEMETRY, emqx_telemetry).
-rlog_shard({?COMMON_SHARD, ?TELEMETRY}).
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------
%% Mnesia bootstrap %% Mnesia bootstrap
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------
@ -146,9 +148,9 @@ init([Opts]) ->
[] -> [] ->
Enabled = proplists:get_value(enabled, Opts, true), Enabled = proplists:get_value(enabled, Opts, true),
UUID = generate_uuid(), UUID = generate_uuid(),
mnesia:dirty_write(?TELEMETRY, #telemetry{id = ?UNIQUE_ID, ekka_mnesia:dirty_write(?TELEMETRY, #telemetry{id = ?UNIQUE_ID,
uuid = UUID, uuid = UUID,
enabled = Enabled}), enabled = Enabled}),
State#state{enabled = Enabled, uuid = UUID}; State#state{enabled = Enabled, uuid = UUID};
[#telemetry{uuid = UUID, enabled = Enabled} | _] -> [#telemetry{uuid = UUID, enabled = Enabled} | _] ->
State#state{enabled = Enabled, uuid = UUID} State#state{enabled = Enabled, uuid = UUID}
@ -162,16 +164,16 @@ init([Opts]) ->
end. end.
handle_call(enable, _From, State = #state{uuid = UUID}) -> handle_call(enable, _From, State = #state{uuid = UUID}) ->
mnesia:dirty_write(?TELEMETRY, #telemetry{id = ?UNIQUE_ID, ekka_mnesia:dirty_write(?TELEMETRY, #telemetry{id = ?UNIQUE_ID,
uuid = UUID, uuid = UUID,
enabled = true}), enabled = true}),
_ = erlang:send(self(), first_report), _ = erlang:send(self(), first_report),
{reply, ok, State#state{enabled = true}}; {reply, ok, State#state{enabled = true}};
handle_call(disable, _From, State = #state{uuid = UUID}) -> handle_call(disable, _From, State = #state{uuid = UUID}) ->
mnesia:dirty_write(?TELEMETRY, #telemetry{id = ?UNIQUE_ID, ekka_mnesia:dirty_write(?TELEMETRY, #telemetry{id = ?UNIQUE_ID,
uuid = UUID, uuid = UUID,
enabled = false}), enabled = false}),
{reply, ok, State#state{enabled = false}}; {reply, ok, State#state{enabled = false}};
handle_call(is_enabled, _From, State = #state{enabled = Enabled}) -> handle_call(is_enabled, _From, State = #state{enabled = Enabled}) ->