public abstract class Invalidator extends Object
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 and Description |
---|
Invalidator(String serviceName,
IFunction<EventRegistration,Boolean> eventFilter,
NodeEngine nodeEngine) |
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.
|
protected final int partitionCount
protected final String serviceName
protected final ILogger logger
protected final NodeEngine nodeEngine
protected final EventService eventService
protected final MetaDataGenerator metaDataGenerator
protected final IPartitionService partitionService
protected final IFunction<EventRegistration,Boolean> eventFilter
public Invalidator(String serviceName, IFunction<EventRegistration,Boolean> eventFilter, NodeEngine nodeEngine)
protected abstract void invalidateInternal(Invalidation invalidation, int orderKey)
public final void invalidateKey(Data key, String dataStructureName, String sourceUuid)
key
- key of the entry to be removed from Near CachedataStructureName
- name of the data structure to be invalidatedpublic final void invalidateAllKeys(String dataStructureName, String sourceUuid)
dataStructureName
- name of the data structure to be clearedpublic final MetaDataGenerator getMetaDataGenerator()
public final void resetPartitionMetaData(String dataStructureName, int partitionId)
protected Invalidation newInvalidation(Data key, String dataStructureName, String sourceUuid, int partitionId)
protected final void sendImmediately(Invalidation invalidation, int orderKey)
public void destroy(String dataStructureName, String sourceUuid)
MapRemoteService.destroyDistributedObject(String)
dataStructureName
- name of the data structure.MapRemoteService.destroyDistributedObject(String)
public void reset()
ManagedService.reset()
ManagedService.reset()
public void shutdown()
ManagedService.shutdown(boolean)
ManagedService.shutdown(boolean)
Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.