Package org.infinispan.conflict.impl

Interface StateReceiver<K,V>

All Known Implementing Classes:

StateReceiverImpl

public interface StateReceiver<K,V>

Since:

9.1

Author:

Ryan Emerson

Method Summary

Modifier and Type	Method	Description
void	cancelRequests()	Cancels all ongoing replica requests.
CompletableFuture<List<Map<Address,CacheEntry<K,V>>>>	getAllReplicasForSegment(int segmentId, LocalizedCacheTopology topology, long timeout)	Return all replicas of a cache entry for a given segment.
void	receiveState(Address sender, int topologyId, Collection<StateChunk> stateChunks)

Method Detail

cancelRequests

void cancelRequests()

Cancels all ongoing replica requests.

getAllReplicasForSegment

CompletableFuture<List<Map<Address,CacheEntry<K,V>>>> getAllReplicasForSegment(int segmentId,
                                                                                           LocalizedCacheTopology topology,
                                                                                           long timeout)

Return all replicas of a cache entry for a given segment. We require the ConsitentHash to be passed here, as it is necessary for the hash of the last stable topology to be utilised during an automatic merge, before a new merged topology is installed.

Throws:

IllegalStateException - if this method is invoked whilst a previous request for Replicas is still executing

receiveState

void receiveState(Address sender,
                  int topologyId,
                  Collection<StateChunk> stateChunks)