Преглед изворни кода

fix: fix static check warning, add some fields schema

EMQ-YangM пре 3 година
родитељ
комит
3fa8447c85
2 измењених фајлова са 5 додато и 2 уклоњено
  1. 1 1
      apps/emqx_authz/src/emqx_authz.erl
  2. 4 1
      apps/emqx_authz/src/emqx_authz_schema.erl

+ 1 - 1
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) ->

+ 4 - 1
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") ->
     [