|
|
@@ -425,17 +425,7 @@ get_backend_module() ->
|
|
|
|
|
|
create_resource(Context, #{type := built_in_database} = Cfg) ->
|
|
|
emqx_retainer_mnesia:create_resource(Cfg),
|
|
|
- Context;
|
|
|
-create_resource(Context, #{type := DB} = Config) ->
|
|
|
- ResourceID = erlang:iolist_to_binary([io_lib:format("~ts_~ts", [?APP, DB])]),
|
|
|
- _ = emqx_resource:create(
|
|
|
- ResourceID,
|
|
|
- <<"emqx_retainer">>,
|
|
|
- list_to_existing_atom(io_lib:format("~ts_~ts", [emqx_connector, DB])),
|
|
|
- Config,
|
|
|
- #{}
|
|
|
- ),
|
|
|
- Context#{resource_id => ResourceID}.
|
|
|
+ Context.
|
|
|
|
|
|
-spec close_resource(context()) -> ok | {error, term()}.
|
|
|
close_resource(#{resource_id := ResourceId}) ->
|