Module riak_core_handoff_manager

Behaviours: gen_server.

Data Types

ho_stats()

ho_stats() = #ho_stats{interval_end = erlang:timestamp(), last_update = erlang:timestamp(), objs = non_neg_integer(), bytes = non_neg_integer()}

ho_type()

ho_type() = ownership | hinted | repair | resize

index()

index() = chash:index_as_int()

mod_partition()

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

mod_src_tgt()

mod_src_tgt() = {module(), index(), index()} | {undefined, undefined, undefined}

Function Index

add_exclusion/2
add_inbound/1
add_outbound/6
add_outbound/7
code_change/3
get_concurrency/0
get_exclusions/1
handle_call/3
handle_cast/2
handle_info/2
handoff_change_enabled_setting/2
init/1
kill_handoffs/0
kill_handoffs_in_direction/1
kill_xfer/3Kill the transfer of ModSrcTarget with Reason.
remove_exclusion/2
set_concurrency/1
set_recv_data/2Associate Data with the inbound handoff Recv.
start_link/0
status/0
status/1
status_update/2Send status updates Stats to the handoff manager for a particular handoff identified by ModSrcTgt.
terminate/2
xfer/3Initiate a transfer from SrcPartition to TargetPartition for the given Module using the FilterModFun filter.

Function Details

add_exclusion/2

add_exclusion(Module, Index) -> any()

add_inbound/1

add_inbound(SSLOpts) -> any()

add_outbound/6

add_outbound(HOType, Module, Idx, Node, VnodePid, Opts) -> any()

add_outbound/7

add_outbound(HOType, Module, SrcIdx, TargetIdx, Node, VnodePid, Opts) -> any()

code_change/3

code_change(OldVsn, State, Extra) -> any()

get_concurrency/0

get_concurrency() -> any()

get_exclusions/1

get_exclusions(Module) -> any()

handle_call/3

handle_call(X1, From, State) -> any()

handle_cast/2

handle_cast(X1, State) -> any()

handle_info/2

handle_info(X1, State) -> any()

handoff_change_enabled_setting/2

handoff_change_enabled_setting(EnOrDis, Direction) -> any()

init/1

init(X1) -> any()

kill_handoffs/0

kill_handoffs() -> any()

kill_handoffs_in_direction/1

kill_handoffs_in_direction(Direction::inbound | outbound) -> ok

kill_xfer/3

kill_xfer(SrcNode::node(), ModSrcTarget::tuple(), Reason::any()) -> ok

Kill the transfer of ModSrcTarget with Reason.

remove_exclusion/2

remove_exclusion(Module, Index) -> any()

set_concurrency/1

set_concurrency(Limit) -> any()

set_recv_data/2

set_recv_data(Recv::pid(), Data::proplists:proplist()) -> ok

Associate Data with the inbound handoff Recv.

start_link/0

start_link() -> any()

status/0

status() -> any()

status/1

status(Filter) -> any()

status_update/2

status_update(ModSrcTgt::mod_src_tgt(), Stats::ho_stats()) -> ok

Send status updates Stats to the handoff manager for a particular handoff identified by ModSrcTgt.

terminate/2

terminate(Reason, State) -> any()

xfer/3

xfer(X1::{index(), node()}, X2::mod_partition(), FilterModFun::{module(), atom()}) -> ok

Initiate a transfer from SrcPartition to TargetPartition for the given Module using the FilterModFun filter.


Generated by EDoc