|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface DistributionManager
A component that manages the distribution of elements across a cache cluster
Method Summary | |
---|---|
Collection<Address> |
getAffectedNodes(Collection<Object> affectedKeys)
A helper method that retrieves a list of nodes affected by operations on a set of keys. |
ConsistentHash |
getConsistentHash()
Retrieves the consistent hash instance currently in use, an instance of the configured ConsistentHash class (which defaults to DefaultConsistentHash . |
DataLocality |
getLocality(Object key)
Returns the data locality characteristics of a given key. |
Address |
getPrimaryLocation(Object key)
Returns the first Address containing the key. |
ConsistentHash |
getReadConsistentHash()
|
ConsistentHash |
getWriteConsistentHash()
|
boolean |
isAffectedByRehash(Object key)
Tests whether a given key is affected by a rehash that may be in progress. |
boolean |
isJoinComplete()
Tests whether the current instance has completed joining the cluster |
boolean |
isLocal(Object key)
Deprecated. |
boolean |
isRehashInProgress()
Tests whether a rehash is in progress |
List<Address> |
locate(Object key)
Locates a key in a cluster. |
Set<Address> |
locateAll(Collection<Object> keys)
Locates a list of keys in a cluster. |
Method Detail |
---|
@Deprecated boolean isLocal(Object key)
getLocality(Object)
instead.
key
- key to test
DataLocality getLocality(Object key)
key
- key to test
List<Address> locate(Object key)
key
- key to test
Address getPrimaryLocation(Object key)
locate(Object)
key
- key to test
Set<Address> locateAll(Collection<Object> keys)
locate(Object)
the returned addresses may not be owners
of the keys if a rehash happens to be in progress or is pending, so when querying these servers, invalid responses
should be checked for and the next address checked accordingly.
keys
- list of keys to test
ConsistentHash getConsistentHash()
DefaultConsistentHash
.
ConsistentHash getReadConsistentHash()
ConsistentHash getWriteConsistentHash()
boolean isAffectedByRehash(Object key)
key
- key to test
boolean isRehashInProgress()
boolean isJoinComplete()
Collection<Address> getAffectedNodes(Collection<Object> affectedKeys)
locateAll(java.util.Collection)
and then combine the result addresses.
affectedKeys
- keys to locate
|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |