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

feat: add ets table creation to jwt supervisor

This commit is contained in:
Thales Macedo Garitezi 2022-10-31 15:08:25 -03:00
parent b4837302aa
commit a33977e635
1 changed files with 15 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
apps/emqx_rule_engine/src/emqx_rule_engine_jwt_sup.erl
View File

@ -25,12 +25,15 @@
-export([init/1]). -export([init/1]).
-include_lib("emqx_rule_engine/include/rule_actions.hrl").
-type worker_id() :: term(). -type worker_id() :: term().
start_link() -> start_link() ->
supervisor:start_link({local, ?MODULE}, ?MODULE, []). supervisor:start_link({local, ?MODULE}, ?MODULE, []).
init([]) -> init([]) ->
ensure_jwt_table(),
SupFlags = #{ strategy => one_for_one SupFlags = #{ strategy => one_for_one
, intensity => 10 , intensity => 10
, period => 5 , period => 5
@ -73,3 +76,15 @@ jwt_worker_child_spec(Id, Config, Ref) ->
, shutdown => brutal_kill , shutdown => brutal_kill
, modules => [emqx_rule_engine_jwt_worker] , modules => [emqx_rule_engine_jwt_worker]
}. }.
-spec ensure_jwt_table() -> ok.
ensure_jwt_table() ->
case ets:whereis(?JWT_TABLE) of
undefined ->
Opts = [named_table, public,
{read_concurrency, true}, ordered_set],
_ = ets:new(?JWT_TABLE, Opts),
ok;
_ ->
ok
end.