Module riak_ensemble_msg

Data Types

extra_check() = undefined | fun(([peer_reply()]) -> boolean())

future() = undefined | pid()

maybe_pid() = pid() | undefined

msg() = term()

msg_from() = {riak_ensemble_msg, pid(), reference()}

abstract datatype: msg_state()

peer_id() = {term(), node()}

peer_pids() = [{peer_id(), maybe_pid()}]

peer_reply() = {peer_id(), term()}

required() = quorum | other | all | all_or_quorum

views() = [[peer_id()]]

blocking_send_all(Msg::msg(), Id::peer_id(), Peers::peer_pids(), Views::views()) -> {future(), msg_state()}

blocking_send_all(Msg::msg(), Id::peer_id(), Peers::peer_pids(), Views::views(), Required::required()) -> {future(), msg_state()}

blocking_send_all(Msg::msg(), Id::peer_id(), Peers::peer_pids(), Views::views(), Required::required(), Extra::extra_check()) -> {future(), msg_state()}

cast_all(Msg::msg(), Id::peer_id(), Peers::peer_pids()) -> ok

handle_reply(ReqId::any(), Peer::peer_id(), Reply::any(), MsgState::msg_state()) -> msg_state()

quorum_timeout(Msgstate::msg_state()) -> msg_state()

reply(X1::msg_from(), Id::peer_id(), Reply::any()) -> ok

send_all(Msg::msg(), Id::peer_id(), Peers::peer_pids(), Views::views()) -> msg_state()

send_all(Msg::msg(), Id::peer_id(), Peers::peer_pids(), Views::views(), Required::required()) -> msg_state()

wait_for_quorum(Pid::future()) -> {quorum_met, [peer_reply()]} | {timeout, [peer_reply()]}

Generated by EDoc