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

fix(plugin): get plugin config api

This commit is contained in:
JimMoen 2024-04-25 13:49:54 +08:00
parent f343cd2021
commit b0aa3bb70f
No known key found for this signature in database
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
apps/emqx_plugins/src/emqx_plugins.erl
View File

@ -51,7 +51,7 @@
ensure_stopped/1, ensure_stopped/1,
get_plugin_config/1, get_plugin_config/1,
get_plugin_config/2, get_plugin_config/2,
put_plugin_config/4, put_plugin_config/3,
restart/1, restart/1,
list/0 list/0
]). ]).
@ -249,7 +249,7 @@ ensure_stopped(NameVsn) ->
-spec get_plugin_config(name_vsn()) -> -spec get_plugin_config(name_vsn()) ->
{ok, plugin_config()} | {error, term()}. {ok, plugin_config()} | {error, term()}.
get_plugin_config(NameVsn) -> get_plugin_config(NameVsn) ->
get_plugin_config(NameVsn, #{format => ?CONFIG_FORMAT_MAP}). get_plugin_config(bin(NameVsn), #{format => ?CONFIG_FORMAT_MAP}).
-spec get_plugin_config(name_vsn(), Options :: map()) -> -spec get_plugin_config(name_vsn(), Options :: map()) ->
{ok, avro_binary() | plugin_config()} {ok, avro_binary() | plugin_config()}
@ -260,12 +260,12 @@ get_plugin_config(NameVsn, #{format := ?CONFIG_FORMAT_AVRO}) ->
{error, _Reason} = Err -> Err {error, _Reason} = Err -> Err
end; end;
get_plugin_config(NameVsn, #{format := ?CONFIG_FORMAT_MAP}) -> get_plugin_config(NameVsn, #{format := ?CONFIG_FORMAT_MAP}) ->
persistent_term:get(?PLUGIN_PERSIS_CONFIG_KEY(NameVsn), #{}). {ok, persistent_term:get(?PLUGIN_PERSIS_CONFIG_KEY(NameVsn), #{})}.
%% @doc Update plugin's config. %% @doc Update plugin's config.
%% RPC call from Management API or CLI. %% RPC call from Management API or CLI.
%% the avro binary and plugin config ALWAYS be valid before calling this function. %% the avro binary and plugin config ALWAYS be valid before calling this function.
put_plugin_config(NameVsn, AvroJsonMap, DecodedPluginConfig) -> put_plugin_config(NameVsn, AvroJsonMap, _DecodedPluginConfig) ->
AvroJsonBin = emqx_utils_json:encode(AvroJsonMap), AvroJsonBin = emqx_utils_json:encode(AvroJsonMap),
ok = write_avro_bin(NameVsn, AvroJsonBin), ok = write_avro_bin(NameVsn, AvroJsonBin),
ok = persistent_term:put(?PLUGIN_PERSIS_CONFIG_KEY(NameVsn), AvroJsonMap), ok = persistent_term:put(?PLUGIN_PERSIS_CONFIG_KEY(NameVsn), AvroJsonMap),