Behaviours: gen_server.
ho_type() = ownership | hinted | repair | resize
index() = chash:index_as_int()
known_handoff() = {{module(), index()}, {ho_type() | delete, inbound | outbound | local, node() | '$resize' | '$delete'}}
mod_partition() = {module(), index()}
partition() = chash:index_as_int()
| all_handoffs/0 | Get all handoffs known by this manager. |
| all_index_pid/1 | |
| all_vnodes/0 | |
| all_vnodes/1 | |
| all_vnodes_status/0 | |
| force_handoffs/0 | Provided for support/debug purposes. |
| get_tab/0 | |
| get_vnode_pid/2 | |
| handle_info/2 | |
| kill_repairs/1 | |
| repair/3 | Repair the given ModPartition pair for Service using the
given FilterModFun to filter keys. |
| repair_status/1 | Get the status of the repair process for a given ModPartition. |
| start_link/0 | |
| start_vnode/2 | |
| stop/0 | |
| unregister_vnode/2 | |
| unregister_vnode/3 | |
| vnode_event/4 | |
| xfer_complete/2 |
all_handoffs() -> [known_handoff()]
Get all handoffs known by this manager.
all_index_pid(VNodeMod) -> any()
all_vnodes() -> any()
all_vnodes(Mod) -> any()
all_vnodes_status() -> any()
force_handoffs() -> any()
Provided for support/debug purposes. Forces all running vnodes to start handoff. Limited by handoff_concurrency setting and therefore may need to be called multiple times to force all handoffs to complete.
get_tab() -> any()
get_vnode_pid(Index, VNodeMod) -> any()
handle_info(X1, State0) -> any()
kill_repairs(Reason) -> any()
repair(Service::atom(), ModPartition::{module(), partition()}, FilterModFun::{module(), atom()}) -> {ok, Pairs::[{partition(), node()}]} | {down, Down::[{partition(), node()}]} | ownership_change_in_progress
Repair the given ModPartition pair for Service using the
given FilterModFun to filter keys.
repair_status(ModPartition::mod_partition()) -> in_progress | not_found
Get the status of the repair process for a given ModPartition.
start_link() -> any()
start_vnode(Index, VNodeMod) -> any()
stop() -> any()
unregister_vnode(Index, VNodeMod) -> any()
unregister_vnode(Index, Pid, VNodeMod) -> any()
vnode_event(Mod, Idx, Pid, Event) -> any()
xfer_complete(Origin::node(), Xfer::tuple()) -> ok
Generated by EDoc