Module riak_core_vnode_master

dispatch to vnodes.

Behaviours: gen_server.

Description

dispatch to vnodes

Data Types

keyspaces()

keyspaces() = [{partition(), [partition()]}]

partition()

partition() = chash:index_as_int()

sender()

sender() = {sender_type(), reference() | tuple(), pid()} | {server, undefined, undefined} | {fsm, undefined, pid()} | ignore

sender_type()

sender_type() = fsm | server | raw

vnode_req()

vnode_req() = term()

Function Index

all_nodes/1(Deprecated.)
command/3
command/4
command_return_vnode/4
command_unreliable/3
command_unreliable/4
coverage/5
get_vnode_pid/2
handle_call/3
handle_cast/2
handle_info/2
make_coverage_request/4
make_request/3
reg_name/1
start_link/1
start_link/2
start_link/3
start_vnode/2
sync_command/3
sync_command/4
sync_spawn_command/3

Function Details

all_nodes/1

all_nodes(VNodeMod) -> any()

This function is deprecated: Provided for compatibility with older vnode master API. New code should use riak_core_vnode_manager:all_vnode/1 which returns a mod/index/pid list rather than just a pid list.

command/3

command(Preflist, Msg, VMaster) -> any()

command/4

command(PrefListOrCmd, Msg, Sender, VMaster) -> any()

command_return_vnode/4

command_return_vnode(X1, Msg, Sender, VMaster) -> any()

command_unreliable/3

command_unreliable(Preflist, Msg, VMaster) -> any()

command_unreliable/4

command_unreliable(PrefListOrCmd, Msg, Sender, VMaster) -> any()

coverage/5

coverage(Msg, CoverageVNodes, Keyspaces, Sender, VMaster) -> any()

get_vnode_pid/2

get_vnode_pid(Index, VNodeMod) -> any()

handle_call/3

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

handle_cast/2

handle_cast(Req, State) -> any()

handle_info/2

handle_info(Info, State) -> any()

make_coverage_request/4

make_coverage_request(Request::vnode_req(), KeySpaces::keyspaces(), Sender::sender(), Index::partition()) -> #riak_coverage_req_v1{index = partition(), keyspaces = keyspaces(), sender = sender(), request = vnode_req()}

make_request/3

make_request(Request::vnode_req(), Sender::sender(), Index::partition()) -> #riak_vnode_req_v1{index = partition(), sender = sender(), request = vnode_req()}

reg_name/1

reg_name(VNodeMod) -> any()

start_link/1

start_link(VNodeMod) -> any()

start_link/2

start_link(VNodeMod, LegacyMod) -> any()

start_link/3

start_link(VNodeMod, LegacyMod, Service) -> any()

start_vnode/2

start_vnode(Index, VNodeMod) -> any()

sync_command/3

sync_command(IndexNode, Msg, VMaster) -> any()

sync_command/4

sync_command(X1, Msg, VMaster, Timeout) -> any()

sync_spawn_command/3

sync_spawn_command(X1, Msg, VMaster) -> any()


Generated by EDoc