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

refactor(resource): add resource recreate fun with empty opts

This commit is contained in:
JimMoen 2022-05-09 10:11:44 +08:00
parent 16b6c2f849
commit a5ddc5390f
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
apps/emqx_resource/src/emqx_resource.erl
View File

@ -56,7 +56,9 @@
create_dry_run/2, create_dry_run/2,
create_dry_run_local/2, create_dry_run_local/2,
%% this will do create_dry_run, stop the old instance and start a new one %% this will do create_dry_run, stop the old instance and start a new one
recreate/3,
recreate/4, recreate/4,
recreate_local/3,
recreate_local/4, recreate_local/4,
%% remove the config and stop the instance %% remove the config and stop the instance
remove/1, remove/1,
@ -200,11 +202,21 @@ create_dry_run(ResourceType, Config) ->
create_dry_run_local(ResourceType, Config) -> create_dry_run_local(ResourceType, Config) ->
emqx_resource_manager:create_dry_run(ResourceType, Config). emqx_resource_manager:create_dry_run(ResourceType, Config).
-spec recreate(instance_id(), resource_type(), resource_config()) ->
{ok, resource_data()} | {error, Reason :: term()}.
recreate(InstId, ResourceType, Config) ->
recreate(InstId, ResourceType, Config, #{}).
-spec recreate(instance_id(), resource_type(), resource_config(), create_opts()) -> -spec recreate(instance_id(), resource_type(), resource_config(), create_opts()) ->
{ok, resource_data()} | {error, Reason :: term()}. {ok, resource_data()} | {error, Reason :: term()}.
recreate(InstId, ResourceType, Config, Opts) -> recreate(InstId, ResourceType, Config, Opts) ->
wrap_rpc(emqx_resource_proto_v1:recreate(InstId, ResourceType, Config, Opts)). wrap_rpc(emqx_resource_proto_v1:recreate(InstId, ResourceType, Config, Opts)).
-spec recreate_local(instance_id(), resource_type(), resource_config()) ->
{ok, resource_data()} | {error, Reason :: term()}.
recreate_local(InstId, ResourceType, Config) ->
recreate_local(InstId, ResourceType, Config, #{}).
-spec recreate_local(instance_id(), resource_type(), resource_config(), create_opts()) -> -spec recreate_local(instance_id(), resource_type(), resource_config(), create_opts()) ->
{ok, resource_data()} | {error, Reason :: term()}. {ok, resource_data()} | {error, Reason :: term()}.
recreate_local(InstId, ResourceType, Config, Opts) -> recreate_local(InstId, ResourceType, Config, Opts) ->