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

Modifier and Type	Method and 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 the ScatteredVersionManager.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

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 the ScatteredVersionManager.SegmentState.NOT_OWNED state.

Parameters:

topologyId -