View Source mqtt_sessions_registry (mqtt_sessions v2.8.0)

Registry for all the sessions in a namespace

Summary

client_id(Pool)

Generate a new (random) ClientID of 20 bytes. A ClientID may be 1 to 23 utf8 encoded bytes.

Find the session process for the given pool name and client.

init(_)

Force a session to close, no DISCONNECT to be sent.

routing_id(Pool)

Generate a new (random) RoutingId of 22 bytes. A ClientID may be 1 to 23 utf8 encoded bytes.

start_link()

whois(Pid)

Find the name and pool for the session process

-spec client_id(atom()) -> binary().

Generate a new (random) ClientID of 20 bytes. A ClientID may be 1 to 23 utf8 encoded bytes.

-spec find_session(atom(), binary() | pid()) -> {ok, pid()} | {error, notfound}.

Find the session process for the given pool name and client.

-spec init([]) -> {ok, #state{}}.

-spec kill_session(atom(), binary()) -> ok.

Force a session to close, no DISCONNECT to be sent.

-spec register(atom(), binary(), pid()) -> ok | {error, duplicate}.

-spec routing_id(atom()) -> binary().

Generate a new (random) RoutingId of 22 bytes. A ClientID may be 1 to 23 utf8 encoded bytes.

-spec start_link() -> {ok, pid()} | {error, term()}.

-spec whois(pid()) -> {ok, {atom(), binary()}} | {error, notfound}.

Find the name and pool for the session process