feat(emqx_limiter): add support for update overall limiter
This commit is contained in:
parent
51e62468ed
commit
eb003e3305
|
@ -23,6 +23,7 @@
|
||||||
, init/4 %% XXX: Compatible with before 4.2 version
|
, init/4 %% XXX: Compatible with before 4.2 version
|
||||||
, info/1
|
, info/1
|
||||||
, check/2
|
, check/2
|
||||||
|
, update_overall_limiter/4
|
||||||
]).
|
]).
|
||||||
|
|
||||||
-record(limiter, {
|
-record(limiter, {
|
||||||
|
@ -152,3 +153,15 @@ is_message_limiter(conn_messages_in) -> true;
|
||||||
is_message_limiter(conn_messages_routing) -> true;
|
is_message_limiter(conn_messages_routing) -> true;
|
||||||
is_message_limiter(overall_messages_routing) -> true;
|
is_message_limiter(overall_messages_routing) -> true;
|
||||||
is_message_limiter(_) -> false.
|
is_message_limiter(_) -> false.
|
||||||
|
|
||||||
|
update_overall_limiter(Zone, Name, Capacity, Interval) ->
|
||||||
|
case is_overall_limiter(Name) of
|
||||||
|
false -> false;
|
||||||
|
_ ->
|
||||||
|
try
|
||||||
|
esockd_limiter:update({Zone, Name}, Capacity, Interval),
|
||||||
|
true
|
||||||
|
catch _:_:_ ->
|
||||||
|
false
|
||||||
|
end
|
||||||
|
end.
|
||||||
|
|
Loading…
Reference in New Issue