View Source gen_cluster (gen_cluster v0.3.0)

-type builtin_discovery() ::
          {dns, gc_discover_dns_ip:options() | gc_discover_dns_srv:options()} |
          {static, gc_discover_static:options()} |
          {epmd_all, gc_discover_epmd_all:options()}.

cb_state()

-type cb_state() :: term().

config()

-type config() :: [option()].

option()

-type option() ::
          {discovery, builtin_discovery() | {module(), term()}} |
          {dist, module()} |
          {refresh_interval_ms, integer() | undefined}.

peer()

-type peer() :: #{node := atom(), port => inet:port_number()}.

peers()

-type peers() :: sets:set(peer()).

Functions

active/3

callback_mode()

code_change/4

inactive/3

init/1

-spec init([config()]) ->
              gen_statem:init_result(inactive | active,
                                     #data{discovery :: {module(), cb_state()},
                                           dist :: {module(), cb_state()},
                                           refresh_interval_ms :: integer() | infinity}).

nodes_to_peers(Nodes)

-spec nodes_to_peers([node()]) -> peers().

start_link(Configuration)

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

terminate(Reason, State, Data)