Package | Description |
---|---|
net.sf.ehcache.cluster |
This package contains the API for accessing the cluster node topology and registering to receive events about changes in the cluster node topology.
|
net.sf.ehcache.constructs.nonstop.store |
Ehcache-nonstopcache behaviors package
|
net.sf.ehcache.terracotta |
This package contains the Terracotta integration functionalities.
|
Modifier and Type | Method and Description |
---|---|
ClusterNode |
CacheCluster.getCurrentNode()
Retrieves the
ClusterNode instance that corresponds to the current node. |
ClusterNode |
NoopCacheCluster.getCurrentNode()
Retrieves the
ClusterNode instance that corresponds to the current node. |
ClusterNode |
CacheCluster.waitUntilNodeJoinsCluster()
Waits until the current node has successfully joined the cluster.
|
ClusterNode |
NoopCacheCluster.waitUntilNodeJoinsCluster()
Waits until the current node has successfully joined the cluster.
|
Modifier and Type | Method and Description |
---|---|
java.util.Collection<ClusterNode> |
CacheCluster.getNodes()
Get all the nodes in the cluster
|
java.util.Collection<ClusterNode> |
NoopCacheCluster.getNodes()
Get all the nodes in the cluster
|
Modifier and Type | Method and Description |
---|---|
void |
ClusterTopologyListener.clusterOffline(ClusterNode node)
This node has lost contact (possibly temporarily) with the cluster and cannot execute
clustered operations
|
void |
ClusterTopologyListener.clusterOnline(ClusterNode node)
This node has established contact with the cluster and can execute clustered operations.
|
void |
ClusterTopologyListener.clusterRejoined(ClusterNode oldNode,
ClusterNode newNode)
This node lost contact and rejoined the cluster again.
|
void |
ClusterTopologyListener.nodeJoined(ClusterNode node)
A node has joined the cluster
|
void |
ClusterTopologyListener.nodeLeft(ClusterNode node)
A node has left the cluster
|
Modifier and Type | Method and Description |
---|---|
void |
ExecutorServiceStore.ClusterStatusListener.clusterOffline(ClusterNode node)
This node has lost contact (possibly temporarily) with the cluster and cannot execute
clustered operations
|
void |
ExecutorServiceStore.ClusterStatusListener.clusterOnline(ClusterNode node)
This node has established contact with the cluster and can execute clustered operations.
|
void |
ExecutorServiceStore.ClusterStatusListener.clusterRejoined(ClusterNode oldNode,
ClusterNode newNode)
This node lost contact and rejoined the cluster again.
|
void |
ExecutorServiceStore.ClusterStatusListener.nodeJoined(ClusterNode node)
A node has joined the cluster
|
void |
ExecutorServiceStore.ClusterStatusListener.nodeLeft(ClusterNode node)
A node has left the cluster
|
Modifier and Type | Class and Description |
---|---|
class |
DisconnectedClusterNode
ClusterNode which copies a disconnected ClusterNode without keeping any reference to the original one.
|
Modifier and Type | Field and Description |
---|---|
private ClusterNode |
TerracottaClient.NodeLeftListener.currentNode |
private ClusterNode |
TerracottaClient.FireRejoinEventListener.currentNode |
private ClusterNode |
TerracottaClient.RejoinRequest.oldNode |
Modifier and Type | Method and Description |
---|---|
ClusterNode |
TerracottaCacheCluster.getCurrentNode()
Retrieves the
ClusterNode instance that corresponds to the current node. |
ClusterNode |
TerracottaClient.RejoinRequest.getRejoinOldNode() |
ClusterNode |
TerracottaCacheCluster.waitUntilNodeJoinsCluster()
Waits until the current node has successfully joined the cluster.
|
Modifier and Type | Method and Description |
---|---|
java.util.Collection<ClusterNode> |
TerracottaCacheCluster.getNodes()
Get all the nodes in the cluster
|
Modifier and Type | Method and Description |
---|---|
void |
TerracottaClient.RejoinRequestHolder.addRejoinRequest(ClusterNode oldNode) |
void |
TerracottaClient.NodeLeftListener.clusterOffline(ClusterNode node)
This node has lost contact (possibly temporarily) with the cluster and cannot execute
clustered operations
|
void |
TerracottaClient.FireRejoinEventListener.clusterOffline(ClusterNode node)
This node has lost contact (possibly temporarily) with the cluster and cannot execute
clustered operations
|
void |
TerracottaClient.NodeLeftListener.clusterOnline(ClusterNode node)
This node has established contact with the cluster and can execute clustered operations.
|
void |
TerracottaClient.FireRejoinEventListener.clusterOnline(ClusterNode node)
This node has established contact with the cluster and can execute clustered operations.
|
void |
TerracottaClient.NodeLeftListener.clusterRejoined(ClusterNode oldNode,
ClusterNode newNode)
This node lost contact and rejoined the cluster again.
|
void |
TerracottaClient.FireRejoinEventListener.clusterRejoined(ClusterNode oldNode,
ClusterNode newNode)
This node lost contact and rejoined the cluster again.
|
private void |
TerracottaClient.RejoinWorker.fireClusterRejoinedEvent(ClusterNode oldNodeReference) |
(package private) void |
TerracottaCacheCluster.fireNodeRejoinedEvent(ClusterNode oldNode,
ClusterNode newNode)
Fire Rejoin event to all listeners.
|
private void |
TerracottaCacheCluster.fireRejoinEvent(ClusterNode oldNode,
ClusterNode newNode,
ClusterTopologyListener listener) |
void |
TerracottaClient.NodeLeftListener.nodeJoined(ClusterNode node)
A node has joined the cluster
|
void |
TerracottaClient.FireRejoinEventListener.nodeJoined(ClusterNode node)
A node has joined the cluster
|
void |
TerracottaClient.NodeLeftListener.nodeLeft(ClusterNode node)
A node has left the cluster
|
void |
TerracottaClient.FireRejoinEventListener.nodeLeft(ClusterNode node)
A node has left the cluster
|
private void |
TerracottaClient.rejoinCluster(ClusterNode oldNode)
Rejoins the cluster
|
void |
TerracottaClient.RejoinWorker.startRejoin(ClusterNode oldNode) |
Constructor and Description |
---|
DisconnectedClusterNode(ClusterNode node)
Constructor accepting the disconnected node
|
FireRejoinEventListener(ClusterNode currentNode,
java.util.concurrent.CountDownLatch latch)
Constructor
|
NodeLeftListener(TerracottaClient client,
ClusterNode currentNode)
Constructor accepting the client and the node to listen for
|
RejoinRequest(ClusterNode oldNode) |