Module syn_registry

Behaviours: gen_server.

Function Index

add_to_local_table/5
code_change/3
count/0
count/1
find_monitor_for_pid/1
force_cluster_sync/0
handle_call/3
handle_cast/2
handle_info/2
init/1
multicast_loop/0
register/2
register/3
remove_from_local_table/2
start_link/0
sync_demonitor_and_kill_on_node/5
sync_get_local_registry_tuples/1
sync_register/6
sync_unregister/3
terminate/2
unregister/1
unregister_and_register/2
unregister_and_register/3
whereis/1
whereis/2

Function Details

add_to_local_table/5

add_to_local_table(Name::any(), Pid::pid(), Meta::any(), Time::integer(), MonitorRef::undefined | reference()) -> ok

code_change/3

code_change(OldVsn::any(), State::#state{custom_event_handler = undefined | module(), anti_entropy_interval_ms = undefined | non_neg_integer(), anti_entropy_interval_max_deviation_ms = undefined | non_neg_integer(), multicast_pid = undefined | pid()}, Extra::any()) -> {ok, #state{custom_event_handler = undefined | module(), anti_entropy_interval_ms = undefined | non_neg_integer(), anti_entropy_interval_max_deviation_ms = undefined | non_neg_integer(), multicast_pid = undefined | pid()}}

count/0

count() -> non_neg_integer()

count/1

count(Node::node()) -> non_neg_integer()

find_monitor_for_pid/1

find_monitor_for_pid(Pid::pid()) -> reference() | undefined

force_cluster_sync/0

force_cluster_sync() -> ok

handle_call/3

handle_call(Request::any(), From::any(), State::#state{custom_event_handler = undefined | module(), anti_entropy_interval_ms = undefined | non_neg_integer(), anti_entropy_interval_max_deviation_ms = undefined | non_neg_integer(), multicast_pid = undefined | pid()}) -> {reply, Reply::any(), #state{custom_event_handler = undefined | module(), anti_entropy_interval_ms = undefined | non_neg_integer(), anti_entropy_interval_max_deviation_ms = undefined | non_neg_integer(), multicast_pid = undefined | pid()}} | {reply, Reply::any(), #state{custom_event_handler = undefined | module(), anti_entropy_interval_ms = undefined | non_neg_integer(), anti_entropy_interval_max_deviation_ms = undefined | non_neg_integer(), multicast_pid = undefined | pid()}, Timeout::non_neg_integer()} | {noreply, #state{custom_event_handler = undefined | module(), anti_entropy_interval_ms = undefined | non_neg_integer(), anti_entropy_interval_max_deviation_ms = undefined | non_neg_integer(), multicast_pid = undefined | pid()}} | {noreply, #state{custom_event_handler = undefined | module(), anti_entropy_interval_ms = undefined | non_neg_integer(), anti_entropy_interval_max_deviation_ms = undefined | non_neg_integer(), multicast_pid = undefined | pid()}, Timeout::non_neg_integer()} | {stop, Reason::any(), Reply::any(), #state{custom_event_handler = undefined | module(), anti_entropy_interval_ms = undefined | non_neg_integer(), anti_entropy_interval_max_deviation_ms = undefined | non_neg_integer(), multicast_pid = undefined | pid()}} | {stop, Reason::any(), #state{custom_event_handler = undefined | module(), anti_entropy_interval_ms = undefined | non_neg_integer(), anti_entropy_interval_max_deviation_ms = undefined | non_neg_integer(), multicast_pid = undefined | pid()}}

handle_cast/2

handle_cast(Msg::any(), State::#state{custom_event_handler = undefined | module(), anti_entropy_interval_ms = undefined | non_neg_integer(), anti_entropy_interval_max_deviation_ms = undefined | non_neg_integer(), multicast_pid = undefined | pid()}) -> {noreply, #state{custom_event_handler = undefined | module(), anti_entropy_interval_ms = undefined | non_neg_integer(), anti_entropy_interval_max_deviation_ms = undefined | non_neg_integer(), multicast_pid = undefined | pid()}} | {noreply, #state{custom_event_handler = undefined | module(), anti_entropy_interval_ms = undefined | non_neg_integer(), anti_entropy_interval_max_deviation_ms = undefined | non_neg_integer(), multicast_pid = undefined | pid()}, Timeout::non_neg_integer()} | {stop, Reason::any(), #state{custom_event_handler = undefined | module(), anti_entropy_interval_ms = undefined | non_neg_integer(), anti_entropy_interval_max_deviation_ms = undefined | non_neg_integer(), multicast_pid = undefined | pid()}}

handle_info/2

handle_info(Info::any(), State::#state{custom_event_handler = undefined | module(), anti_entropy_interval_ms = undefined | non_neg_integer(), anti_entropy_interval_max_deviation_ms = undefined | non_neg_integer(), multicast_pid = undefined | pid()}) -> {noreply, #state{custom_event_handler = undefined | module(), anti_entropy_interval_ms = undefined | non_neg_integer(), anti_entropy_interval_max_deviation_ms = undefined | non_neg_integer(), multicast_pid = undefined | pid()}} | {noreply, #state{custom_event_handler = undefined | module(), anti_entropy_interval_ms = undefined | non_neg_integer(), anti_entropy_interval_max_deviation_ms = undefined | non_neg_integer(), multicast_pid = undefined | pid()}, Timeout::non_neg_integer()} | {stop, Reason::any(), #state{custom_event_handler = undefined | module(), anti_entropy_interval_ms = undefined | non_neg_integer(), anti_entropy_interval_max_deviation_ms = undefined | non_neg_integer(), multicast_pid = undefined | pid()}}

init/1

init(X1::[]) -> {ok, #state{custom_event_handler = undefined | module(), anti_entropy_interval_ms = undefined | non_neg_integer(), anti_entropy_interval_max_deviation_ms = undefined | non_neg_integer(), multicast_pid = undefined | pid()}} | {ok, #state{custom_event_handler = undefined | module(), anti_entropy_interval_ms = undefined | non_neg_integer(), anti_entropy_interval_max_deviation_ms = undefined | non_neg_integer(), multicast_pid = undefined | pid()}, Timeout::non_neg_integer()} | ignore | {stop, Reason::any()}

multicast_loop/0

multicast_loop() -> terminated

register/2

register(Name::any(), Pid::pid()) -> ok | {error, Reason::any()}

register/3

register(Name::any(), Pid::pid(), Meta::any()) -> ok | {error, Reason::any()}

remove_from_local_table/2

remove_from_local_table(Name::any(), Pid::pid()) -> ok

start_link/0

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

sync_demonitor_and_kill_on_node/5

sync_demonitor_and_kill_on_node(Name::any(), Pid::pid(), Meta::any(), MonitorRef::reference(), Kill::boolean()) -> ok

sync_get_local_registry_tuples/1

sync_get_local_registry_tuples(FromNode::node()) -> [syn_registry_tuple()]

sync_register/6

sync_register(RemoteNode::node(), Name::any(), RemotePid::pid(), RemoteMeta::any(), RemoteTime::integer(), Force::boolean()) -> ok

sync_unregister/3

sync_unregister(RemoteNode::node(), Name::any(), Pid::pid()) -> ok

terminate/2

terminate(Reason::any(), State::#state{custom_event_handler = undefined | module(), anti_entropy_interval_ms = undefined | non_neg_integer(), anti_entropy_interval_max_deviation_ms = undefined | non_neg_integer(), multicast_pid = undefined | pid()}) -> terminated

unregister/1

unregister(Name::any()) -> ok | {error, Reason::any()}

unregister_and_register/2

unregister_and_register(Name::any(), Pid::pid()) -> ok | {error, Reason::any()}

unregister_and_register/3

unregister_and_register(Name::any(), Pid::pid(), Meta::any()) -> ok | {error, Reason::any()}

whereis/1

whereis(Name::any()) -> pid() | undefined

whereis/2

whereis(Name::any(), X2::with_meta) -> {pid(), Meta::any()} | undefined


Generated by EDoc