|
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 StateProvider
Handles outbound state transfers.
Method Summary | |
---|---|
void |
cancelOutboundTransfer(Address destination,
int topologyId,
Set<Integer> segments)
Cancel sending of cache entries that belong to the given set of segments. |
List<TransactionInfo> |
getTransactionsForSegments(Address destination,
int topologyId,
Set<Integer> segments)
Gets the list of transactions that affect keys from the given segments. |
boolean |
isStateTransferInProgress()
|
void |
onTopologyUpdate(CacheTopology cacheTopology,
boolean isRebalance)
Receive notification of topology changes. |
void |
start()
|
void |
startOutboundTransfer(Address destination,
int topologyId,
Set<Integer> segments)
Start to send cache entries that belong to the given set of segments. |
void |
stop()
Cancels all outbound state transfers. |
Method Detail |
---|
boolean isStateTransferInProgress()
void onTopologyUpdate(CacheTopology cacheTopology, boolean isRebalance)
cacheTopology
- isRebalance
- List<TransactionInfo> getTransactionsForSegments(Address destination, int topologyId, Set<Integer> segments) throws InterruptedException
destination
- the address of the requestertopologyId
- segments
-
InterruptedException
void startOutboundTransfer(Address destination, int topologyId, Set<Integer> segments) throws InterruptedException
destination
- the address of the requestertopologyId
- segments
-
InterruptedException
void cancelOutboundTransfer(Address destination, int topologyId, Set<Integer> segments)
destination
- the address of the requestertopologyId
- segments
- the segments that we have to cancel transfer forvoid start()
void stop()
|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |