public class DefaultLocalCacheStrategy extends Object implements CacheFactoryStrategy
Cache
,
CacheFactory
Constructor and Description |
---|
DefaultLocalCacheStrategy() |
Modifier and Type | Method and Description |
---|---|
Cache |
createCache(String name)
Creates a new cache for the cache name specified.
|
void |
destroyCache(Cache cache)
Destroys the supplied cache.
|
void |
doClusterTask(ClusterTask task)
Invokes a task on other cluster members in an asynchronous fashion.
|
void |
doClusterTask(ClusterTask task,
byte[] nodeID)
Invokes a task on other the specified cluster member in an asynchronous fashion.
|
Collection<Object> |
doSynchronousClusterTask(ClusterTask task,
boolean includeLocalMember)
Invokes a task on other cluster members synchronously and returns the result as a Collection
(method will not return until the task has been executed on each cluster member).
|
Object |
doSynchronousClusterTask(ClusterTask task,
byte[] nodeID)
Invokes a task on a given cluster member synchronously and returns the result of
the remote operation.
|
byte[] |
getClusterMemberID()
Returns a byte[] that uniquely identifies this member within the cluster or
null
when not in a cluster. |
ClusterNodeInfo |
getClusterNodeInfo(byte[] nodeID)
Returns the node info for the given cluster node
|
Collection<ClusterNodeInfo> |
getClusterNodesInfo()
Returns basic information about the current members of the cluster or an empty
collection if not running in a cluster.
|
long |
getClusterTime()
Gets the pseudo-synchronized time from the cluster.
|
Lock |
getLock(Object key,
Cache cache)
Returns an existing lock on the specified key or creates a new one if none was found.
|
int |
getMaxClusterNodes()
Returns the maximum number of cluster members allowed.
|
String |
getPluginName()
Get the plugin name corresponding to this clustering implementation
|
byte[] |
getSeniorClusterMemberID()
Returns a byte[] that uniquely identifies this senior cluster member or
null
when not in a cluster. |
boolean |
isSeniorClusterMember()
Returns true if this node is the maste node of the cluster.
|
boolean |
startCluster()
Returns true if the cluster has been started.
|
void |
stopCluster()
Stops the cluster.
|
void |
updateCacheStats(Map<String,Cache> caches)
Updates the statistics of the specified caches and publishes them into
a cache for statistics.
|
public boolean startCluster()
CacheFactoryStrategy
An error should be logged when the cluster fails to be started.
startCluster
in interface CacheFactoryStrategy
public void stopCluster()
CacheFactoryStrategy
stopCluster
in interface CacheFactoryStrategy
public Cache createCache(String name)
CacheFactoryStrategy
createCache
in interface CacheFactoryStrategy
name
- name of the cache to create.public void destroyCache(Cache cache)
CacheFactoryStrategy
destroyCache
in interface CacheFactoryStrategy
cache
- the cache to destroy.public boolean isSeniorClusterMember()
CacheFactoryStrategy
isSeniorClusterMember
in interface CacheFactoryStrategy
public Collection<ClusterNodeInfo> getClusterNodesInfo()
CacheFactoryStrategy
getClusterNodesInfo
in interface CacheFactoryStrategy
public int getMaxClusterNodes()
CacheFactoryStrategy
getMaxClusterNodes
in interface CacheFactoryStrategy
public byte[] getSeniorClusterMemberID()
CacheFactoryStrategy
null
when not in a cluster.getSeniorClusterMemberID
in interface CacheFactoryStrategy
public byte[] getClusterMemberID()
CacheFactoryStrategy
null
when not in a cluster.getClusterMemberID
in interface CacheFactoryStrategy
public long getClusterTime()
CacheFactoryStrategy
getClusterTime
in interface CacheFactoryStrategy
public void doClusterTask(ClusterTask task)
CacheFactoryStrategy
doClusterTask
in interface CacheFactoryStrategy
task
- the task to be invoked on all other cluster members.public void doClusterTask(ClusterTask task, byte[] nodeID)
CacheFactoryStrategy
doClusterTask
in interface CacheFactoryStrategy
task
- the task to be invoked on the specified cluster member.nodeID
- the byte array that identifies the target cluster member.public Collection<Object> doSynchronousClusterTask(ClusterTask task, boolean includeLocalMember)
CacheFactoryStrategy
doSynchronousClusterTask
in interface CacheFactoryStrategy
task
- the ClusterTask object to be invoked on all other cluster members.includeLocalMember
- true to run the task on the local member, false otherwisepublic Object doSynchronousClusterTask(ClusterTask task, byte[] nodeID)
CacheFactoryStrategy
doSynchronousClusterTask
in interface CacheFactoryStrategy
task
- the ClusterTask object to be invoked on a given cluster member.nodeID
- the byte array that identifies the target cluster member.public void updateCacheStats(Map<String,Cache> caches)
CacheFactoryStrategy
The statistics cache must contain a long array of 5 positions for each cache with the following content:
updateCacheStats
in interface CacheFactoryStrategy
caches
- caches to get their stats and publish them in a statistics cache.public String getPluginName()
CacheFactoryStrategy
getPluginName
in interface CacheFactoryStrategy
public Lock getLock(Object key, Cache cache)
CacheFactoryStrategy
getLock
in interface CacheFactoryStrategy
key
- the object that defines the visibility or scope of the lock.cache
- the cache used for holding the lock.public ClusterNodeInfo getClusterNodeInfo(byte[] nodeID)
CacheFactoryStrategy
getClusterNodeInfo
in interface CacheFactoryStrategy
nodeID
- The target cluster nodeCopyright © 2003–2019 Ignite Realtime. All rights reserved.