diff --git a/apps/emqx_authz/src/emqx_authz.erl b/apps/emqx_authz/src/emqx_authz.erl index b584c32e3..a493e339d 100644 --- a/apps/emqx_authz/src/emqx_authz.erl +++ b/apps/emqx_authz/src/emqx_authz.erl @@ -257,7 +257,7 @@ init_sources(Sources) -> true -> ?SLOG(info, #{msg => "disabled_sources_ignored", sources => Disabled}); false -> ok end, - lists:map(fun init_metrics/1, Sources), + ok = lists:foreach(fun init_metrics/1, Sources), lists:map(fun init_source/1, Sources). init_source(#{enable := false} = Source) -> diff --git a/apps/emqx_authz/src/emqx_authz_schema.erl b/apps/emqx_authz/src/emqx_authz_schema.erl index e34a8e8d7..25545db8d 100644 --- a/apps/emqx_authz/src/emqx_authz_schema.erl +++ b/apps/emqx_authz/src/emqx_authz_schema.erl @@ -167,7 +167,10 @@ fields("metrics") -> {"matched", mk(integer(), #{desc => ?DESC("matched")})}, {"allow", mk(integer(), #{desc => ?DESC("allow")})}, {"deny", mk(integer(), #{desc => ?DESC("deny")})}, - {"ignore", mk(float(), #{desc => ?DESC("ignore")})} + {"ignore", mk(float(), #{desc => ?DESC("ignore")})}, + {"rate", mk(float(), #{desc => ?DESC("rate")})}, + {"rate_max", mk(float(), #{desc => ?DESC("rate_max")})}, + {"rate_last5m", mk(float(), #{desc => ?DESC("rate_last5m")})} ]; fields("node_metrics") -> [