| Overview |  |
cluster_state() = riak_ensemble_state:state()
ensemble_data() = {ensemble_id(), leader_id(), vsn_views(), vsn_views()}
ensemble_id() = term()
ensemble_info() = #ensemble_info{vsn = vsn(), mod = module(), args = [any()], leader = leader_id(), views = [[peer_id()]], seq = {integer(), integer()}}
ensembles() = orddict(ensemble_id(), ensemble_data())
epoch() = integer()
leader_id() = undefined | peer_id()
orddict(Key, Val) = [{Key, Val}]
peer_id() = {term(), node()}
peer_info() = nodedown | undefined | {any(), boolean(), epoch()}
seq() = integer()
state() = #state{version = integer(), ensemble_data = ensembles(), remote_peers = orddict(peer_id(), pid()), cluster_state = cluster_state()}
views() = [[peer_id()]]
vsn_views() = {vsn(), views()}
check_quorum(Ensemble::ensemble_id(), Timeout::timeout()) -> boolean()
cluster() -> [node()]
code_change(OldVsn, State, Extra) -> any()
count_quorum(Ensemble::ensemble_id(), Timeout::timeout()) -> integer()
create_ensemble(EnsembleId::ensemble_id(), PeerId::peer_id(), Mod::module(), Args::[any()]) -> ok | {error, term()}
create_ensemble(EnsembleId::ensemble_id(), EnsLeader::leader_id(), Members::[peer_id()], Mod::module(), Args::[any()]) -> ok | {error, term()}
enable() -> ok | error
enabled() -> boolean()
get_cluster_state() -> cluster_state()
get_leader(EnsembleId::ensemble_id()) -> leader_id()
get_leader_pid(Ensemble::ensemble_id()) -> undefined | pid()
get_members(EnsembleId::ensemble_id()) -> [peer_id()]
get_peer_info(Ensemble::ensemble_id(), Peer::peer_id()) -> nodedown | undefined | peer_info()
get_peer_pid(Ensemble::ensemble_id(), PeerId::peer_id()) -> pid() | undefined
get_pending(EnsembleId::ensemble_id()) -> {vsn(), [[peer_id()]]} | undefined
get_views(EnsembleId::ensemble_id()) -> {vsn(), views()}
gossip(CS) -> any()
gossip_pending(Ensemble, Vsn, Views) -> any()
handle_call(Request, From, State) -> any()
handle_cast(Msg, State) -> any()
handle_info(Info, State) -> any()
init(X1::[]) -> {ok, state()}
join(Same, OtherNode) -> any()
known_ensembles() -> undefined | {ok, orddict(ensemble_id(), ensemble_info())}
remove(Same, NodeToRemove) -> any()
rleader_pid() -> pid() | undefined
start() -> ignore | {error, term()} | {ok, pid()}
start_link() -> ignore | {error, term()} | {ok, pid()}
terminate(Reason, State) -> any()
update_ensemble(Ensemble::ensemble_id(), Leader::peer_id(), Views::views(), Vsn::vsn()) -> ok
Generated by EDoc