com.hazelcast.internal.nearcache.impl.invalidation

Class MetaDataFetcher

java.lang.Object

com.hazelcast.internal.nearcache.impl.invalidation.MetaDataFetcher

Direct Known Subclasses:

ClientCacheMetaDataFetcher, ClientMapMetaDataFetcher, MemberMapMetaDataFetcher

public abstract class MetaDataFetcher
extends Object

Runs on near-cache side, an instance of this task is responsible for fetching of all near-caches' remote metadata like last sequence numbers and partition-uuids. To see usage of this metadata visit: MetaDataGenerator.

This class is abstract to provide different implementations on client and member sides.

Field Summary

Fields

Modifier and Type	Field and Description
protected ILogger	logger

Constructor Summary

Constructors

Constructor and Description
MetaDataFetcher(ILogger logger)

Method Summary

Modifier and Type	Method and Description
protected abstract Collection<Map.Entry<Integer,UUID>>	assignAndGetUuids() Gets or assigns partition-uuids before start of RepairingTask and returns a list of partition-id, partition-uuid pairs.
void	fetchMetadata(ConcurrentMap<String,RepairingHandler> handlers)
protected abstract void	process(InternalCompletableFuture future, ConcurrentMap<String,RepairingHandler> handlers)
protected void	repairSequences(Collection<Map.Entry<String,List<Map.Entry<Integer,Long>>>> namePartitionSequenceList, ConcurrentMap<String,RepairingHandler> handlers)
protected void	repairUuids(Collection<Map.Entry<Integer,UUID>> uuids, ConcurrentMap<String,RepairingHandler> handlers)
protected abstract List<InternalCompletableFuture>	scanMembers(List<String> names)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

logger

protected final ILogger logger

Constructor Detail

MetaDataFetcher

public MetaDataFetcher(ILogger logger)

Method Detail

scanMembers

protected abstract List<InternalCompletableFuture> scanMembers(List<String> names)

process

protected abstract void process(InternalCompletableFuture future,
                                ConcurrentMap<String,RepairingHandler> handlers)

assignAndGetUuids

protected abstract Collection<Map.Entry<Integer,UUID>> assignAndGetUuids()
                                                                  throws Exception

Gets or assigns partition-uuids before start of RepairingTask and returns a list of partition-id, partition-uuid pairs.

This method is likely to be called only one time during the life-cycle of a client.

Returns:

list of partition-id, partition-uuid pairs for initialization

Throws:

Exception - possible exceptions raised by remote calls

fetchMetadata

public final void fetchMetadata(ConcurrentMap<String,RepairingHandler> handlers)

repairUuids

protected void repairUuids(Collection<Map.Entry<Integer,UUID>> uuids,
                           ConcurrentMap<String,RepairingHandler> handlers)

repairSequences

protected void repairSequences(Collection<Map.Entry<String,List<Map.Entry<Integer,Long>>>> namePartitionSequenceList,
                               ConcurrentMap<String,RepairingHandler> handlers)