com.hazelcast.internal.nearcache.impl.invalidation

Class Invalidator

java.lang.Object

com.hazelcast.internal.nearcache.impl.invalidation.Invalidator

Direct Known Subclasses:

BatchInvalidator, NonStopInvalidator

public abstract class Invalidator
extends Object

Contains shared functionality for Near Cache invalidation.

Field Summary

Fields

Modifier and Type	Field and Description
protected IFunction<EventRegistration,Boolean>	eventFilter
protected EventService	eventService
protected ILogger	logger
protected MetaDataGenerator	metaDataGenerator
protected NodeEngine	nodeEngine
protected int	partitionCount
protected IPartitionService	partitionService
protected String	serviceName

Constructor Summary

Constructors

Constructor and Description
Invalidator(String serviceName, IFunction<EventRegistration,Boolean> eventFilter, NodeEngine nodeEngine)

Method Summary

Modifier and Type	Method and Description
void	destroy(String dataStructureName, String sourceUuid) Removes supplied data structures invalidation queues and flushes their content.
MetaDataGenerator	getMetaDataGenerator()
void	invalidateAllKeys(String dataStructureName, String sourceUuid) Invalidates all keys from Near Caches of supplied data structure name.
protected abstract void	invalidateInternal(Invalidation invalidation, int orderKey)
void	invalidateKey(Data key, String dataStructureName, String sourceUuid) Invalidates supplied key from Near Caches of supplied data structure name.
protected Invalidation	newInvalidation(Data key, String dataStructureName, String sourceUuid, int partitionId)
void	reset() Resets this invalidator back to its initial state.
void	resetPartitionMetaData(String dataStructureName, int partitionId)
protected void	sendImmediately(Invalidation invalidation, int orderKey)
void	shutdown() Shuts down this invalidator and releases used resources.

Methods inherited from class java.lang.Object

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

Field Detail

partitionCount

protected final int partitionCount

serviceName

protected final String serviceName

logger

protected final ILogger logger

nodeEngine

protected final NodeEngine nodeEngine

eventService

protected final EventService eventService

metaDataGenerator

protected final MetaDataGenerator metaDataGenerator

partitionService

protected final IPartitionService partitionService

eventFilter

protected final IFunction<EventRegistration,Boolean> eventFilter

Constructor Detail

Invalidator

public Invalidator(String serviceName,
                   IFunction<EventRegistration,Boolean> eventFilter,
                   NodeEngine nodeEngine)

Method Detail

invalidateInternal

protected abstract void invalidateInternal(Invalidation invalidation,
                                           int orderKey)

invalidateKey

public final void invalidateKey(Data key,
                                String dataStructureName,
                                String sourceUuid)

Invalidates supplied key from Near Caches of supplied data structure name.

Parameters:

key - key of the entry to be removed from Near Cache

dataStructureName - name of the data structure to be invalidated

invalidateAllKeys

public final void invalidateAllKeys(String dataStructureName,
                                    String sourceUuid)

Invalidates all keys from Near Caches of supplied data structure name.

Parameters:

dataStructureName - name of the data structure to be cleared

getMetaDataGenerator

public final MetaDataGenerator getMetaDataGenerator()

resetPartitionMetaData

public final void resetPartitionMetaData(String dataStructureName,
                                         int partitionId)

newInvalidation

protected Invalidation newInvalidation(Data key,
                                       String dataStructureName,
                                       String sourceUuid,
                                       int partitionId)

sendImmediately

protected final void sendImmediately(Invalidation invalidation,
                                     int orderKey)

destroy

public void destroy(String dataStructureName,
                    String sourceUuid)

Removes supplied data structures invalidation queues and flushes their content. This method is called when removing a Near Cache for example with MapRemoteService.destroyDistributedObject(String)

Parameters:

dataStructureName - name of the data structure.

See Also:

MapRemoteService.destroyDistributedObject(String)

reset

public void reset()

Resets this invalidator back to its initial state. Aimed to call with ManagedService.reset()

See Also:

ManagedService.reset()

shutdown

public void shutdown()

Shuts down this invalidator and releases used resources. Aimed to call with ManagedService.shutdown(boolean)

See Also:

ManagedService.shutdown(boolean)