Package org.infinispan.scattered
Interface ScatteredStateProvider
-
- All Superinterfaces:
StateProvider
- All Known Implementing Classes:
ScatteredStateProviderImpl
public interface ScatteredStateProvider extends StateProvider
- Author:
- Radim Vansa <rvansa@redhat.com>
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description CompletableFuture<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(org.infinispan.commons.util.IntSet segments, Address origin)
-
Methods inherited from interface org.infinispan.statetransfer.StateProvider
cancelOutboundTransfer, getClusterListenersToInstall, getTransactionsForSegments, isStateTransferInProgress, onTopologyUpdate, start, startOutboundTransfer, stop
-
-
-
-
Method Detail
-
startKeysTransfer
void startKeysTransfer(org.infinispan.commons.util.IntSet segments, Address origin)
-
confirmRevokedSegments
CompletableFuture<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
-
-
-