com.hazelcast.internal.nearcache.impl.invalidation

Class MetaDataGenerator

java.lang.Object

com.hazelcast.internal.nearcache.impl.invalidation.MetaDataGenerator

public class MetaDataGenerator
extends Object

Responsible for partition-sequence and partition UUID generation. Used by invalidator to generate metadata for invalidation events.

This metadata is used by RepairingHandler and RepairingTask to act against possible invalidation-miss and partition-loss.

One instance per service is created. Used on member side.

Constructor Summary

Constructors

Constructor and Description
MetaDataGenerator(int partitionCount)

Method Summary

Modifier and Type	Method and Description
long	currentSequence(String name, int partitionId)
void	destroyMetaDataFor(String dataStructureName)
UUID	getOrCreateUuid(int partitionId)
ConcurrentMap<String,AtomicLongArray>	getSequenceGenerators()
UUID	getUuidOrNull(int partitionId)
long	nextSequence(String name, int partitionId)
void	regenerateUuid(int partitionId)
void	removeUuidAndSequence(int partitionId)
void	resetSequence(String name, int partitionId)
void	setCurrentSequence(String name, int partitionId, long sequence)
void	setUuid(int partitionId, UUID uuid)

Methods inherited from class java.lang.Object

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

Constructor Detail

MetaDataGenerator

public MetaDataGenerator(int partitionCount)

Method Detail

currentSequence

public long currentSequence(String name,
                            int partitionId)

nextSequence

public long nextSequence(String name,
                         int partitionId)

setCurrentSequence

public void setCurrentSequence(String name,
                               int partitionId,
                               long sequence)

getOrCreateUuid

public UUID getOrCreateUuid(int partitionId)

getUuidOrNull

public UUID getUuidOrNull(int partitionId)

setUuid

public void setUuid(int partitionId,
                    UUID uuid)

removeUuidAndSequence

public void removeUuidAndSequence(int partitionId)

destroyMetaDataFor

public void destroyMetaDataFor(String dataStructureName)

regenerateUuid

public void regenerateUuid(int partitionId)

resetSequence

public void resetSequence(String name,
                          int partitionId)

getSequenceGenerators

public ConcurrentMap<String,AtomicLongArray> getSequenceGenerators()