Module syn_groups

Behaviours: gen_server.

Function Index

add_to_local_table/4
code_change/3
count/0
count/1
force_cluster_sync/0
get_group_names/0
get_local_members/1
get_local_members/2
get_members/1
get_members/2
handle_call/3
handle_cast/2
handle_info/2
init/1
join/2
join/3
leave/2
local_member/2
member/2
multi_call/2
multi_call/3
multi_call_and_receive/4
multi_call_reply/2
multicast_loop/0
publish/2
publish_to_local/2
remove_from_local_table/2
start_link/0
sync_get_local_groups_tuples/1
sync_join/4
sync_leave/3
terminate/2

Function Details

add_to_local_table/4

add_to_local_table(GroupName::any(), Pid::pid(), Meta::any(), 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()

force_cluster_sync/0

force_cluster_sync() -> ok

get_group_names/0

get_group_names() -> [GroupName::any()]

get_local_members/1

get_local_members(Name::any()) -> [pid()]

get_local_members/2

get_local_members(GroupName::any(), X2::with_meta) -> [{pid(), Meta::any()}]

get_members/1

get_members(Name::any()) -> [pid()]

get_members/2

get_members(GroupName::any(), X2::with_meta) -> [{pid(), Meta::any()}]

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()}

join/2

join(GroupName::any(), Pid::pid()) -> ok

join/3

join(GroupName::any(), Pid::pid(), Meta::any()) -> ok

leave/2

leave(GroupName::any(), Pid::pid()) -> ok | {error, Reason::any()}

local_member/2

local_member(Pid::pid(), GroupName::any()) -> boolean()

member/2

member(Pid::pid(), GroupName::any()) -> boolean()

multi_call/2

multi_call(GroupName::any(), Message::any()) -> {[{pid(), Reply::any()}], [BadPid::pid()]}

multi_call/3

multi_call(GroupName::any(), Message::any(), Timeout::non_neg_integer()) -> {[{pid(), Reply::any()}], [BadPid::pid()]}

multi_call_and_receive/4

multi_call_and_receive(CollectorPid::pid(), Pid::pid(), Message::any(), Timeout::non_neg_integer()) -> any()

multi_call_reply/2

multi_call_reply(CallerPid::pid(), Reply::any()) -> {syn_multi_call_reply, pid(), Reply::any()}

multicast_loop/0

multicast_loop() -> terminated

publish/2

publish(GroupName::any(), Message::any()) -> {ok, RecipientCount::non_neg_integer()}

publish_to_local/2

publish_to_local(GroupName::any(), Message::any()) -> {ok, RecipientCount::non_neg_integer()}

remove_from_local_table/2

remove_from_local_table(GroupName::any(), Pid::pid()) -> ok | {error, Reason::any()}

start_link/0

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

sync_get_local_groups_tuples/1

sync_get_local_groups_tuples(FromNode::node()) -> [syn_groups_tuple()]

sync_join/4

sync_join(RemoteNode::node(), GroupName::any(), Pid::pid(), Meta::any()) -> ok

sync_leave/3

sync_leave(RemoteNode::node(), GroupName::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


Generated by EDoc