Package org.infinispan.scattered
Interface ScatteredStateProvider
-
- All Superinterfaces:
StateProvider
public interface ScatteredStateProvider extends StateProvider
- Author:
- Radim Vansa <rvansa@redhat.com>
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description java.util.concurrent.CompletableFuture<java.lang.Void>
confirmRevokedSegments(int topologyId)
Confirm that this node has received cache topology with given topologyId and that it has moved all the segments it does not own according to consistent hash to theScatteredVersionManager.SegmentState.NOT_OWNED
state.void
startKeysTransfer(IntSet segments, Address origin)
Start transferring keys and remote metadata for the given segments to the origin.-
Methods inherited from interface org.infinispan.statetransfer.StateProvider
cancelOutboundTransfer, getClusterListenersToInstall, getTransactionsForSegments, isStateTransferInProgress, onTopologyUpdate, start, startOutboundTransfer, stop
-
-
-
-
Method Detail
-
startKeysTransfer
void startKeysTransfer(IntSet segments, Address origin)
Start transferring keys and remote metadata for the given segments to the origin.
-
confirmRevokedSegments
java.util.concurrent.CompletableFuture<java.lang.Void> confirmRevokedSegments(int topologyId)
Confirm that this node has received cache topology with given topologyId and that it has moved all the segments it does not own according to consistent hash to theScatteredVersionManager.SegmentState.NOT_OWNED
state.- Parameters:
topologyId
-
-
-