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

refactor(mgmt_api): Fuzzy filter using `select_table`.

This commit is contained in:
JimMoen 2021-10-08 14:40:27 +08:00
parent 5daef544a0
commit 705ed0ce7b
1 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
apps/emqx_management/src/emqx_mgmt_api.erl
View File

@ -219,6 +219,22 @@ traverse_n_by_one(Tab, K, MatchFun, Start, Limit, Acc) ->
end end
end. end.
select_table(Tab, {Ms, FuzzyFilterFun}, ?FRESH_SELECT, Limit, FmtFun)
when is_function(FuzzyFilterFun) andalso Limit > 0 ->
case ets:select(Tab, Ms, Limit) of
'$end_of_table' ->
{[], ?FRESH_SELECT};
{RawResult, NContinuation} ->
{lists:map(FmtFun, lists:reverse(FuzzyFilterFun(RawResult))), NContinuation}
end;
select_table(_Tab, {_Ms, FuzzyFilterFun}, Continuation, _Limit, FmtFun)
when is_function(FuzzyFilterFun) ->
case ets:select(Continuation) of
'$end_of_table' ->
{[], ?FRESH_SELECT};
{RawResult, NContinuation} ->
{lists:map(FmtFun, lists:reverse(FuzzyFilterFun(RawResult))), NContinuation}
end;
select_table(Tab, Ms, ?FRESH_SELECT, Limit, FmtFun) select_table(Tab, Ms, ?FRESH_SELECT, Limit, FmtFun)
when Limit > 0 -> when Limit > 0 ->
case ets:select(Tab, Ms, Limit) of case ets:select(Tab, Ms, Limit) of