public interface StateProvider
Modifier and Type | Method and Description |
---|---|
void |
cancelOutboundTransfer(Address destination,
int topologyId,
IntSet segments)
Cancel sending of cache entries that belong to the given set of segments.
|
Collection<ClusterListenerReplicateCallable<Object,Object>> |
getClusterListenersToInstall() |
CompletionStage<List<TransactionInfo>> |
getTransactionsForSegments(Address destination,
int topologyId,
IntSet segments)
Gets the list of transactions that affect keys from the given segments.
|
boolean |
isStateTransferInProgress() |
CompletableFuture<Void> |
onTopologyUpdate(CacheTopology cacheTopology,
boolean isRebalance)
Receive notification of topology changes.
|
void |
start() |
void |
startOutboundTransfer(Address destination,
int topologyId,
IntSet segments,
boolean applyState)
Start to send cache entries that belong to the given set of segments.
|
void |
stop()
Cancels all outbound state transfers.
|
boolean isStateTransferInProgress()
CompletableFuture<Void> onTopologyUpdate(CacheTopology cacheTopology, boolean isRebalance)
cacheTopology
- isRebalance
- CompletionStage<List<TransactionInfo>> getTransactionsForSegments(Address destination, int topologyId, IntSet segments)
StateTransferGetTransactionsCommand
.destination
- the address of the requestertopologyId
- required topology before we can start collecting transactionssegments
- only return transactions affecting these segmentsCompletionStage
that completes with the list transactions and locks for the given segmentsCollection<ClusterListenerReplicateCallable<Object,Object>> getClusterListenersToInstall()
void startOutboundTransfer(Address destination, int topologyId, IntSet segments, boolean applyState)
StateTransferStartCommand
.
If the applyState field is set to false, then upon delivery at the destination the cache entries are processed
by a StateReceiver
and are not applied to the local cache.destination
- the address of the requestertopologyId
- segments
- applyState
- void cancelOutboundTransfer(Address destination, int topologyId, IntSet segments)
StateTransferCancelCommand
.destination
- the address of the requestertopologyId
- segments
- the segments that we have to cancel transfer forvoid start()
void stop()
Copyright © 2021 JBoss by Red Hat. All rights reserved.