|
||||||||||
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 | |
---|---|
void |
applyReceivedState(Map<Object,InternalCacheValue> state)
|
CacheStore |
getCacheStoreForRehashing()
Retrieves a cache store if one is available and set up for use in rehashing. |
ConsistentHash |
getConsistentHash()
|
TransactionLogger |
getTransactionLogger()
|
void |
informRehashOnJoin(Address joiner,
boolean starting)
This will cause all nodes to add the joiner to their UnionCH |
boolean |
isAffectedByRehash(Object key)
Tests whether a given key is affected by a rehash that may be in progress. |
boolean |
isLocal(Object key)
|
boolean |
isRehashInProgress()
|
List<Address> |
locate(Object key)
Locates a key in a cluster. |
Map<Object,List<Address>> |
locateAll(Collection<Object> keys)
Locates a list of keys in a cluster. |
void |
notifyJoinComplete(Address joiner)
Notifies a coordinator when a join completes |
List<Address> |
requestPermissionToJoin(Address joiner)
"Asks" a coordinator if a joiner may join. |
InternalCacheEntry |
retrieveFromRemoteSource(Object key)
Retrieves a cache entry from a remote source |
void |
setConsistentHash(ConsistentHash consistentHash)
|
void |
transformForL1(CacheEntry entry)
Transforms a cache entry so it is marked for L1 rather than the primary cache data structure. |
Method Detail |
---|
boolean isLocal(Object key)
List<Address> locate(Object key)
key
- key to test
Map<Object,List<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
void transformForL1(CacheEntry entry)
entry
- entry to transformInternalCacheEntry retrieveFromRemoteSource(Object key) throws Exception
key
- key to look up
Exception
ConsistentHash getConsistentHash()
void setConsistentHash(ConsistentHash consistentHash)
boolean isAffectedByRehash(Object key)
key
- key to test
TransactionLogger getTransactionLogger()
List<Address> requestPermissionToJoin(Address joiner)
joiner
- joiner who wants to join
void notifyJoinComplete(Address joiner)
joiner
- joiner who has completed.void informRehashOnJoin(Address joiner, boolean starting)
joiner
- starting
- CacheStore getCacheStoreForRehashing()
boolean isRehashInProgress()
void applyReceivedState(Map<Object,InternalCacheValue> state)
|
Google Analytics | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |