Public Member Functions | |
this (ILogger logger, char[] name) | |
void | setCache (InternetAddress address) |
void | setTasks (InternetAddress address) |
char[] | toString () |
void | fail () |
bool | isEnabled () |
void | setEnabled (bool enabled) |
bool | request (ConnectionPool pool, ProtocolWriter writer, ProtocolReader reader, out IPayload payload) |
Private Attributes | |
char[] | name |
char[] | port |
ILogger | logger |
bool | enabled |
ConnectionPool | tasks |
ConnectionPool | cache |
Definition at line 925 of file Cluster.d.
|
Construct a node with the provided name. This name should be the network name of the hosting device. Definition at line 942 of file Cluster.d. References logger. |
|
Add a cache/queue reference for the remote node |
|
Add a cache-loader reference for the remote node |
|
Return the name of this node (the network name of the device) Definition at line 977 of file Cluster.d. Referenced by NodeSet::addNode(). |
|
Remove this Node from the cluster. The node is disabled until it is seen to recover. Definition at line 989 of file Cluster.d. References ConnectionPool::close(), setEnabled(), and tasks. Referenced by request(). |
|
Get the current state of this node Definition at line 1002 of file Cluster.d. Referenced by NodeSet::scan(), and NodeSet::selectNode(). |
|
Set the enabled state of this node Definition at line 1014 of file Cluster.d. Referenced by fail(). |
|
request data; fail this Node if we can't connect. Note that we make several attempts to connect before writing the node off as a failure. Definition at line 1035 of file Cluster.d. References ConnectionPool::borrow(), Connection::done(), fail(), ProtocolWriter::flush(), Connection::getConduit(), ProtocolReader::getPayload(), Connection::reset(), and time. Referenced by Cluster::getQueue(), and Cluster::loadCache(). |
|
|
|
|
|
Definition at line 929 of file Cluster.d. Referenced by this(). |
|
|
|
Definition at line 932 of file Cluster.d. Referenced by fail(), and Cluster::loadCache(). |
|
Definition at line 932 of file Cluster.d. Referenced by Cluster::getQueue(). |