leo_rpc_client_manager¶

Description
Function Index
Function Details

leo_rpc_client_conn_manager manages rpc-clients.

Behaviours: `gen_server <gen_server.html>`__.

References

https://github.com/leo-project/leo_rpc/blob/master/src/leo_rpc_client_manager

Description¶

leo_rpc_client_conn_manager manages rpc-clients

Function Index¶

code_change/3	gen_server callback - Module:code_change(OldVsn, State, Extra) -> {ok, NewState} \| {error, Reason}.
connected_nodes/0	Retrieve connected nodes.
handle_call/3	gen_server callback - Module:handle_call(Request, From, State) -> Result.
handle_cast/2	gen_server callback - Module:handle_cast(Request, State) -> Result.
handle_info/2	gen_server callback - Module:handle_info(Info, State) -> Result.
init/1	gen_server callback - Module:init(Args) -> Result.
inspect/0	Inspect whether a node is running or not.
inspect/1	Inspect whether the node is running or not.
is_exists/2	Is already ip/port exists.
start_link/1	Start the server.
status/0	Retrieve the current status.
stop/0	Stop the server.
terminate/2	gen_server callback - Module:terminate(Reason, State).

Function Details¶

code_change/3¶

code_change(OldVsn, State, Extra) -> any()

gen_server callback - Module:code_change(OldVsn, State, Extra) -> {ok, NewState} | {error, Reason}.

connected_nodes/0¶

connected_nodes() -> {ok, [atom()]}

Retrieve connected nodes

handle_call/3¶

handle_call(Request, From, State) -> any()

gen_server callback - Module:handle_call(Request, From, State) -> Result

handle_cast/2¶

handle_cast(Msg, State) -> any()

gen_server callback - Module:handle_cast(Request, State) -> Result

handle_info/2¶

handle_info(Info, State) -> any()

gen_server callback - Module:handle_info(Info, State) -> Result

init/1¶

init(X1) -> any()

gen_server callback - Module:init(Args) -> Result

inspect/0¶

inspect() -> ok

Inspect whether a node is running or not

inspect/1¶

inspect(Node) -> active | inactive

Node = atom()

Inspect whether the node is running or not

is_exists/2¶

is_exists(IP, Port) -> boolean()

IP = string()
Port = pos_integer()

Is already ip/port exists

start_link/1¶

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

Interval = pos_integer()

Start the server

status/0¶

status() -> {ok, [tuple()]}

Retrieve the current status

stop/0¶

stop() -> ok

Stop the server

terminate/2¶

terminate(Reason, State) -> any()

gen_server callback - Module:terminate(Reason, State)