Inheritance diagram for ICluster:
Public Member Functions | |
IChannel | createChannel (char[] channel) |
void | broadcast (IChannel channel, IPayload payload=null) |
IConsumer | createConsumer (IChannel channel, IEvent.Style style, IEventListener notify) |
IPayload | getCache (IChannel channel, char[] key, bool remove) |
IPayload | putCache (IChannel channel, char[] key, IPayload payload) |
IPayload | putQueue (IChannel channel, IPayload payload) |
IPayload | getQueue (IChannel channel) |
void | loadCache (IChannel channel, char[] key, IPayload payload) |
ILogger | getLogger () |
Definition at line 58 of file ICluster.d.
|
Create a channel instance. Every cluster operation has a channel provided as an argument Reimplemented in Cluster. Referenced by Client::createChannel(). |
|
Scatter a payload to all registered listeners. This is akin to multicast. Reimplemented in Cluster. Referenced by NetworkAlert::broadcast(). |
|
Create a listener of the specified style on the given channel. The IEventListener should be called whenever a corresponding cluster event happens. Note that the notification is expected to be on a seperate thread. Reimplemented in Cluster. Referenced by NetworkQueue::createConsumer(), and NetworkAlert::createConsumer(). |
|
Return a cluster cache entry, and optionally remove it from the cluster. Reimplemented in Cluster. |
|
Place a cache entry into the cluster. If there is already a matching entry, it is replaced. Reimplemented in Cluster. |
|
Place a new entry into the cluster queue. This may throw a ClusterFullException when there is no space left within the cluster queues. Reimplemented in Cluster. Referenced by NetworkQueue::put(). |
|
Query the cluster for queued entries on our corresponding channel. Returns, and removes, the first matching entry from the cluster. Reimplemented in Cluster. Referenced by NetworkQueue::get(). |
|
Reimplemented in Cluster. |
|
Return the Logger associated with this cluster Reimplemented in Cluster. Referenced by TaskServer::addConsumer(), and TaskServer::this(). |