public interface DistributionManager
Modifier and Type | Method and Description |
---|---|
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 |
isRehashInProgress()
Tests whether a rehash is in progress
|
List |
locate(Object key)
Locates a key in a cluster.
|
Set |
locateAll(Collection keys)
Locates a list of keys in a cluster.
|
DataLocality getLocality(Object key)
key
- key to testList locate(Object key)
key
- key to testAddress getPrimaryLocation(Object key)
DistributionManager.locate(Object)
key
- key to testSet locateAll(Collection keys)
DistributionManager.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 locateConsistentHash getConsistentHash()
DefaultConsistentHash
.ConsistentHash getReadConsistentHash()
ConsistentHash getWriteConsistentHash()
boolean isAffectedByRehash(Object key)
key
- key to testboolean isRehashInProgress()
boolean isJoinComplete()
Copyright © 2015 JBoss, a division of Red Hat. All rights reserved.