| Overview |  |
channel() = atom()
entries() = [entry()]
entry() = {listen_addr(), channel(), pid()}
listen_addr() = #{ip => inet:ip_address(), port => non_neg_integer()}
node_spec() = #{name => node(), listen_addrs => [listen_addr()], channels => [channel()], parallelism => non_neg_integer()}
t() = dict:dict(node_spec(), [pid()])
| erase/2 | |
| find/2 | Finds connection pids in dictionary either by name or node spec. |
| foreach/2 | Apply a function to all connection entries. |
| new/0 | Creates a new dictionary of connections. |
| prune/2 | Prune all occurrences of a connection pid returns the node where the pruned pid was found. |
| store/3 | Store a connection pid. |
erase(NodeName, Connections) -> any()
find(Node::atom() | node_spec(), Connections::t()) -> {ok, entries()} | {error, not_found}
Finds connection pids in dictionary either by name or node spec.
foreach(Fun::fun((node_spec(), [pid()]) -> ok), Connections::t()) -> ok
Apply a function to all connection entries
new() -> t()
Creates a new dictionary of connections.
prune(Node::pid() | node_spec(), Connections::t()) -> {node_spec(), t()}
Prune all occurrences of a connection pid returns the node where the pruned pid was found
store(Node::node_spec(), Entry::entry(), Connections::t()) -> t()
Store a connection pid
Generated by EDoc