View Source partisan_hyparview_xbot_peer_service_manager (partisan v5.0.0-beta.21)
Link to this section Summary
Types
The epoch_count indicates how many disconnect messages are generated.
The epoch indicates how many times the node is restarted.
Functions
Debugging.
Debugging.
Cast a message to a remote gen_server.
Cast a message to a remote gen_server.
Decode state.
Gensym support for forwarding.
Gensym support for forwarding.
Forward message to registered process on the remote side.
Return local node's view of cluster membership.
Inject a partition.
Attempt to join a remote node.
Leave the cluster.
Remove another node from the cluster.
Return membership list.
Return membership list.
Register a trigger to fire when a connection drops.
Register a trigger to fire when a connection drops.
Register a trigger to fire when a connection opens.
Register a trigger to fire when a connection opens.
Return partitions.
Debugging.
Receive message from a remote manager.
Reserve a slot for the particular tag.
Resolve a partition.
Send message to a remote peer service manager.
Start the peer service manager.
Attempt to join a remote node.
Update membership.
Link to this section Types
-type active() :: sets:set(partisan:node_spec()).
-type config() ::
#{active_max_size := non_neg_integer(),
active_min_size := non_neg_integer(),
active_rwl := non_neg_integer(),
passive_max_size := non_neg_integer(),
passive_rwl := non_neg_integer(),
random_promotion := boolean(),
random_promotion_interval := non_neg_integer(),
shuffle_interval := non_neg_integer(),
shuffle_k_active := non_neg_integer(),
shuffle_k_passive := non_neg_integer(),
xbot_enabled := boolean(),
xbot_interval := non_neg_integer()}.
-type epoch() :: non_neg_integer().
-type epoch_count() :: non_neg_integer().
-type message_id() :: {epoch(), epoch_count()}.
-type message_id_store() :: #{partisan:node_spec() := message_id()}.
-type passive() :: sets:set(partisan:node_spec()).
-type reserved() :: #{atom() := partisan:node_spec()}.
-type t() :: #state{}.
-type tag() :: atom().
Link to this section Functions
-spec cast_message(Term :: partisan_remote_ref:p() | partisan_remote_ref:n() | pid(), MEssage :: partisan:message()) -> ok.
-spec init([]) -> {ok, t()}.
-spec start_link() -> {ok, pid()} | ignore | {error, term()}.
-spec supports_capability(Arg :: atom()) -> boolean().
-spec terminate(term(), t()) -> term().