partisan_static_peer_service_manager (partisan v6.1.0)

Trigger Fun when the connection to Arg closes. With a channel option the trigger is per channel and Fun is passed the channel as a second argument; without one it fires when the node's last connection goes, which is what node monitoring is built on.

on_up(Arg, Fun)

Trigger function on connection open for a given node.

on_up(Node, Fun, Opts)

Trigger Fun when a connection to Arg opens. See on_down/3 for the argument forms and the meaning of the channel option.

partitions()

Return partitions.

receive_message(Peer, Channel, Message)

Receive message from a remote manager.

reserve(Tag)

Reserve a slot for the particular tag.

resolve_partition(Reference)

Resolve a partition.

send_message(Name, Message)

Send message to a remote manager.

start_link()

Same as start_link([]).

supports_capability(Arg)

sync_join(Node)

Join a remote node, returning once the connection is established.

update_members(Nodes)

Replaces the peer set with Nodes. Peers not already known are joined; members and pending peers absent from Nodes are dropped, exactly as leave/1 drops them.

Types

channel_subs/0

-type channel_subs() ::
          #{{'_' | node(), '_' | partisan:channel()} => [partisan_peer_service_manager:on_event_fun()]}.

membership/0

-type membership() :: sets:set(partisan:node_spec()).

node_subs/0

-type node_subs() :: #{'_' | node() => [partisan_peer_service_manager:on_event_fun()]}.

pending/0

-type pending() :: [partisan:node_spec()].

state_t/0

-type state_t() ::
          #state{myself :: partisan:node_spec(),
                 pending :: pending(),
                 membership :: membership(),
                 up_funs :: node_subs(),
                 down_funs :: node_subs(),
                 channel_up_funs :: channel_subs(),
                 channel_down_funs :: channel_subs(),
                 sync_joins :: sync_joins(),
                 up_nodes :: sets:set(node()),
                 up_channels :: sets:set({node(), partisan:channel()})}.

sync_joins/0

-type sync_joins() :: #{partisan:node_spec() => [gen_server:from()]}.

Functions

cast_message(Term, MEssage)

-spec cast_message(Term :: partisan:any_pid() | partisan:any_name(), MEssage :: partisan:message()) ->
                      ok.

cast_message(Node, ServerRef, Message)

Cast a message to a remote gen_server.

cast_message(Name, ServerRef, Message, Options)

Cast a message to a remote gen_server.

decode(State)

Decode state.

forward_message(Term, Message)

Gensym support for forwarding.

forward_message(PidOrName, Message, Opts)

Gensym support for forwarding.

forward_message(Node, ServerRef, Message, Opts)

Forward message to registered process on the remote side.

get_local_state()

Return local node's view of cluster membership.

handle_info(Event, State)

handle_message(_, Channel, State)

inject_partition(Origin, TTL)

Inject a partition.

join(Node)

Attempt to join a remote node.

leave()

Leave the cluster, dropping every peer connection. Membership is reduced to this node.

leave(Node)

Remove a peer from the cluster, dropping its connections. Membership here is explicit, so the peer stays out until it is joined again.

members()

Return membership list.

members_for_orchestration()