|
@@ -57,11 +57,7 @@
|
|
|
-export([
|
|
-export([
|
|
|
create/2,
|
|
create/2,
|
|
|
open/2,
|
|
open/2,
|
|
|
- destroy/1
|
|
|
|
|
-]).
|
|
|
|
|
-
|
|
|
|
|
--export([
|
|
|
|
|
- lookup/2,
|
|
|
|
|
|
|
+ destroy/1,
|
|
|
destroy/2
|
|
destroy/2
|
|
|
]).
|
|
]).
|
|
|
|
|
|
|
@@ -145,8 +141,8 @@
|
|
|
}.
|
|
}.
|
|
|
|
|
|
|
|
-type t() ::
|
|
-type t() ::
|
|
|
- emqx_session_mem:t()
|
|
|
|
|
- | emqx_session_ds:t().
|
|
|
|
|
|
|
+ emqx_session_mem:session()
|
|
|
|
|
+ | emqx_persistent_session_ds:session().
|
|
|
|
|
|
|
|
-define(INFO_KEYS, [
|
|
-define(INFO_KEYS, [
|
|
|
id,
|
|
id,
|
|
@@ -198,10 +194,6 @@ get_mqtt_conf(Zone, Key) ->
|
|
|
%% Existing sessions
|
|
%% Existing sessions
|
|
|
%% -------------------------------------------------------------------
|
|
%% -------------------------------------------------------------------
|
|
|
|
|
|
|
|
--spec lookup(clientinfo(), conninfo()) -> t() | none.
|
|
|
|
|
-lookup(ClientInfo, ConnInfo) ->
|
|
|
|
|
- (choose_impl_mod(ConnInfo)):lookup(ClientInfo).
|
|
|
|
|
-
|
|
|
|
|
-spec destroy(clientinfo(), conninfo()) -> ok.
|
|
-spec destroy(clientinfo(), conninfo()) -> ok.
|
|
|
destroy(ClientInfo, ConnInfo) ->
|
|
destroy(ClientInfo, ConnInfo) ->
|
|
|
(choose_impl_mod(ConnInfo)):destroy(ClientInfo).
|
|
(choose_impl_mod(ConnInfo)):destroy(ClientInfo).
|