Raft

Undocumented in source.

Constructors

this
this(ulong ID, string apiport, string cluster, bool join)
Undocumented in source.

Members

Functions

addPeer
void addPeer(ulong ID, string data)
Undocumented in source. Be warned that the author may not have intended to support it.
delPeer
void delPeer(ulong ID)
Undocumented in source. Be warned that the author may not have intended to support it.
delPropose
void delPropose(HttpBase h)
Undocumented in source. Be warned that the author may not have intended to support it.
propose
void propose(RequestCommand command, HttpBase h)
Undocumented in source. Be warned that the author may not have intended to support it.
proposeConfChange
void proposeConfChange(ConfChange cc)
Undocumented in source. Be warned that the author may not have intended to support it.
publishEntries
bool publishEntries(Entry[] ents)
Undocumented in source. Be warned that the author may not have intended to support it.
readIndex
void readIndex(RequestCommand command, HttpBase h)
Undocumented in source. Be warned that the author may not have intended to support it.
ready
void ready()
Undocumented in source. Be warned that the author may not have intended to support it.
send
void send(Message[] msg)
Undocumented in source. Be warned that the author may not have intended to support it.
step
void step(Message msg)
Undocumented in source. Be warned that the author may not have intended to support it.
tick
void tick()
Undocumented in source. Be warned that the author may not have intended to support it.

Variables

_clients
MessageTransfer[ulong] _clients;
Undocumented in source.
_http
Server!(HttpBase, Raft) _http;
Undocumented in source.
_mutex
Mutex _mutex;
Undocumented in source.
_request
HttpBase[ulong] _request;
Undocumented in source.
_server
Server!(Base, MessageReceiver) _server;
Undocumented in source.
_storage
Storage _storage;
Undocumented in source.

Inherited Members

From Node

ID
ulong ID;
Undocumented in source.
storage
MemoryStorage storage;
Undocumented in source.
node
RawNode node;
Undocumented in source.
join
bool join;
Undocumented in source.
lastIndex
ulong lastIndex;
Undocumented in source.
confstate
ConfState confstate;
Undocumented in source.
snapshotIndex
ulong snapshotIndex;
Undocumented in source.
appliedIndex
ulong appliedIndex;
Undocumented in source.
store
DataStorage store;
Undocumented in source.
publishSnapshot
void publishSnapshot(Snapshot snap)
Undocumented in source. Be warned that the author may not have intended to support it.
entriesToApply
Entry[] entriesToApply(Entry[] ents)
Undocumented in source. Be warned that the author may not have intended to support it.
maybeTriggerSnapshot
void maybeTriggerSnapshot()
Undocumented in source. Be warned that the author may not have intended to support it.
publishEntries
bool publishEntries(Entry[] ents)
Undocumented in source. Be warned that the author may not have intended to support it.

Meta