Module riak_core_vnode_manager

Behaviours: gen_server.

Data Types

ho_type()

ho_type() = ownership | hinted | repair | resize

index()

index() = chash:index_as_int()

known_handoff()

known_handoff() = {{module(), index()}, {ho_type() | delete, inbound | outbound | local, node() | '$resize' | '$delete'}}

mod_partition()

mod_partition() = {module(), index()}

partition()

partition() = chash:index_as_int()

Function Index

all_handoffs/0Get all handoffs known by this manager.
all_index_pid/1
all_vnodes/0
all_vnodes/1
all_vnodes_status/0
force_handoffs/0Provided for support/debug purposes.
get_tab/0
get_vnode_pid/2
handle_info/2
kill_repairs/1
repair/3Repair the given ModPartition pair for Service using the given FilterModFun to filter keys.
repair_status/1Get 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

Function Details

all_handoffs/0

all_handoffs() -> [known_handoff()]

Get all handoffs known by this manager.

all_index_pid/1

all_index_pid(VNodeMod) -> any()

all_vnodes/0

all_vnodes() -> any()

all_vnodes/1

all_vnodes(Mod) -> any()

all_vnodes_status/0

all_vnodes_status() -> any()

force_handoffs/0

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/0

get_tab() -> any()

get_vnode_pid/2

get_vnode_pid(Index, VNodeMod) -> any()

handle_info/2

handle_info(X1, State0) -> any()

kill_repairs/1

kill_repairs(Reason) -> any()

repair/3

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/1

repair_status(ModPartition::mod_partition()) -> in_progress | not_found

Get the status of the repair process for a given ModPartition.

start_link/0

start_link() -> any()

start_vnode/2

start_vnode(Index, VNodeMod) -> any()

stop/0

stop() -> any()

unregister_vnode/2

unregister_vnode(Index, VNodeMod) -> any()

unregister_vnode/3

unregister_vnode(Index, Pid, VNodeMod) -> any()

vnode_event/4

vnode_event(Mod, Idx, Pid, Event) -> any()

xfer_complete/2

xfer_complete(Origin::node(), Xfer::tuple()) -> ok


Generated by EDoc