public interface StateReceiver<K,V>
Modifier and Type | Method and 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) |
void cancelRequests()
CompletableFuture<List<Map<Address,CacheEntry<K,V>>>> getAllReplicasForSegment(int segmentId, LocalizedCacheTopology topology, long timeout)
IllegalStateException
- if this method is invoked whilst a previous request for Replicas is still executingvoid receiveState(Address sender, int topologyId, Collection<StateChunk> stateChunks)
Copyright © 2021 JBoss by Red Hat. All rights reserved.