Package org.apache.ignite.internal.processors.cache

Class GridCacheEventManager

java.lang.Object

org.apache.ignite.internal.processors.cache.GridCacheManagerAdapter

org.apache.ignite.internal.processors.cache.GridCacheEventManager

All Implemented Interfaces:

GridCacheManager

public class GridCacheEventManager
extends GridCacheManagerAdapter

Cache event manager.

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.cache.GridCacheManagerAdapter

cctx, log, starting

Constructor Summary

Constructors

Constructor	Description
GridCacheEventManager()

Method Summary

Modifier and Type	Method	Description
void	addEvent(int type)
void	addEvent(int part, KeyCacheObject key, @Nullable IgniteInternalTx tx, @Nullable GridCacheMvccCandidate owner, int type, @Nullable CacheObject newVal, boolean hasNewVal, @Nullable CacheObject oldVal, boolean hasOldVal, String cloClsName, String taskName, boolean keepBinary)
void	addEvent(int part, KeyCacheObject key, UUID evtNodeId, @Nullable GridCacheMvccCandidate owner, int type, @Nullable CacheObject newVal, boolean hasNewVal, CacheObject oldVal, boolean hasOldVal, String cloClsName, String taskName, boolean keepBinary)
void	addEvent(int part, KeyCacheObject key, UUID evtNodeId, @Nullable IgniteInternalTx tx, @Nullable String txLbl, @Nullable Object lockId, int type, @Nullable CacheObject newVal, boolean hasNewVal, @Nullable CacheObject oldVal, boolean hasOldVal, @Nullable String cloClsName, @Nullable String taskName, boolean keepBinary)
void	addEvent(int part, KeyCacheObject key, UUID nodeId, @Nullable IgniteInternalTx tx, GridCacheMvccCandidate owner, int type, CacheObject newVal, boolean hasNewVal, CacheObject oldVal, boolean hasOldVal, String cloClsName, String taskName, boolean keepBinary)
void	addListener(GridLocalEventListener lsnr, int... evts)	Adds local event listener.
boolean	isRecordable(int type)
void	printMemoryStats()	Prints memory statistics (sizes of internal data structures, etc.).
void	readEvent(KeyCacheObject key, @Nullable IgniteInternalTx tx, @Nullable String txLbl, @Nullable CacheObject val, @Nullable String taskName, boolean keepBinary)
void	removeListener(GridLocalEventListener lsnr)	Removes local event listener.

Methods inherited from class org.apache.ignite.internal.processors.cache.GridCacheManagerAdapter

context, kernalStartInfo, kernalStopInfo, log, onDisconnected, onKernalStart, onKernalStart0, onKernalStop, onKernalStop0, start, start0, startInfo, stop, stop0, stopInfo, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

GridCacheEventManager

public GridCacheEventManager()

Method Detail

addListener

public void addListener(GridLocalEventListener lsnr,
                        int... evts)

Adds local event listener.

Parameters:

lsnr - Listener.

evts - Types of events.

removeListener

public void removeListener(GridLocalEventListener lsnr)

Removes local event listener.

Parameters:

lsnr - Local event listener.

readEvent

public void readEvent(KeyCacheObject key,
                      @Nullable
                      @Nullable IgniteInternalTx tx,
                      @Nullable
                      @Nullable String txLbl,
                      @Nullable
                      @Nullable CacheObject val,
                      @Nullable
                      @Nullable String taskName,
                      boolean keepBinary)

Parameters:

key - Key for event.

tx - Possible surrounding transaction.

txLbl - Possible lable of possible surrounding transaction.

val - Read value.

taskName - Task name.

keepBinary - Keep binary flag.

addEvent

public void addEvent(int part,
                     KeyCacheObject key,
                     @Nullable
                     @Nullable IgniteInternalTx tx,
                     @Nullable
                     @Nullable GridCacheMvccCandidate owner,
                     int type,
                     @Nullable
                     @Nullable CacheObject newVal,
                     boolean hasNewVal,
                     @Nullable
                     @Nullable CacheObject oldVal,
                     boolean hasOldVal,
                     String cloClsName,
                     String taskName,
                     boolean keepBinary)

Parameters:

part - Partition.

key - Key for the event.

tx - Possible surrounding transaction.

owner - Possible surrounding lock.

type - Event type.

newVal - New value.

hasNewVal - Whether new value is present or not.

oldVal - Old value.

hasOldVal - Whether old value is present or not.

cloClsName - Closure class name.

taskName - Task name.

addEvent

public void addEvent(int type)

Parameters:

type - Event type (start or stop).

addEvent

public void addEvent(int part,
                     KeyCacheObject key,
                     UUID nodeId,
                     @Nullable
                     @Nullable IgniteInternalTx tx,
                     GridCacheMvccCandidate owner,
                     int type,
                     CacheObject newVal,
                     boolean hasNewVal,
                     CacheObject oldVal,
                     boolean hasOldVal,
                     String cloClsName,
                     String taskName,
                     boolean keepBinary)

Parameters:

part - Partition.

key - Key for the event.

nodeId - Node ID.

tx - Possible surrounding transaction.

owner - Possible surrounding lock.

type - Event type.

newVal - New value.

hasNewVal - Whether new value is present or not.

oldVal - Old value.

hasOldVal - Whether old value is present or not.

cloClsName - Closure class name.

taskName - Task name.

addEvent

public void addEvent(int part,
                     KeyCacheObject key,
                     UUID evtNodeId,
                     @Nullable
                     @Nullable GridCacheMvccCandidate owner,
                     int type,
                     @Nullable
                     @Nullable CacheObject newVal,
                     boolean hasNewVal,
                     CacheObject oldVal,
                     boolean hasOldVal,
                     String cloClsName,
                     String taskName,
                     boolean keepBinary)

Parameters:

part - Partition.

key - Key for the event.

evtNodeId - Node ID.

owner - Possible surrounding lock.

type - Event type.

newVal - New value.

hasNewVal - Whether new value is present or not.

oldVal - Old value.

hasOldVal - Whether old value is present or not.

cloClsName - Closure class name.

taskName - Task name.

addEvent

public void addEvent(int part,
                     KeyCacheObject key,
                     UUID evtNodeId,
                     @Nullable
                     @Nullable IgniteInternalTx tx,
                     @Nullable
                     @Nullable String txLbl,
                     @Nullable
                     @Nullable Object lockId,
                     int type,
                     @Nullable
                     @Nullable CacheObject newVal,
                     boolean hasNewVal,
                     @Nullable
                     @Nullable CacheObject oldVal,
                     boolean hasOldVal,
                     @Nullable
                     @Nullable String cloClsName,
                     @Nullable
                     @Nullable String taskName,
                     boolean keepBinary)

Parameters:

part - Partition.

key - Key for the event.

evtNodeId - Event node ID.

tx - Possible surrounding transaction.

txLbl - Possible label of possible surrounding transaction.

lockId - Lock ID.

type - Event type.

newVal - New value.

hasNewVal - Whether new value is present or not.

oldVal - Old value.

hasOldVal - Whether old value is present or not.

cloClsName - Closure class name.

taskName - Task class name.

isRecordable

public boolean isRecordable(int type)

Parameters:

type - Event type.

Returns:

True if event is recordable.

printMemoryStats

public void printMemoryStats()

Prints memory statistics (sizes of internal data structures, etc.). NOTE: this method is for testing and profiling purposes only.

Specified by:

printMemoryStats in interface GridCacheManager

Overrides:

printMemoryStats in class GridCacheManagerAdapter