org.gridgain.grid.kernal.processors.cache

Class GridCacheMetricsAdapter

java.lang.Object

org.gridgain.grid.kernal.processors.cache.GridCacheMetricsAdapter

All Implemented Interfaces:

Externalizable, Serializable, GridCacheMetrics

public class GridCacheMetricsAdapter
extends Object
implements GridCacheMetrics, Externalizable

Adapter for cache metrics.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GridCacheMetricsAdapter() No-args constructor.
GridCacheMetricsAdapter(boolean isDrSndCache, boolean isDrRcvCache)
GridCacheMetricsAdapter(GridCacheMetrics m)

Method Summary

Methods

Modifier and Type	Method and Description
long	commitTime() Gets last time transaction was committed.
static GridCacheMetricsAdapter	copyOf(GridCacheMetrics m) Create a copy of given metrics object.
long	createTime() Gets create time of the owning entity (either cache or entry).
void	delegate(GridCacheMetricsAdapter delegate)
GridDrReceiverCacheMetrics	drReceiveMetrics() Gets metrics for data received during data center replication, if data center replication is not configured then IllegalStateException will be thrown.
GridDrSenderCacheMetrics	drSendMetrics() Gets metrics for data sent during data center replication, if data center replication is not configured then IllegalStateException will be thrown.
int	hits() Gets total number of hits for the owning entity (either cache or entry).
int	misses() Gets total number of misses for the owning entity (either cache or entry).
void	onPauseStateChanged(GridDrPauseReason pauseReason, String errMsg) Callback for replication pause state changed.
void	onRead(boolean isHit) Cache read callback.
void	onReceiveCacheConflictResolved(boolean usedNew, boolean usedOld, boolean usedMerge) Callback for conflict resolver on receiver cache side.
void	onReceiveCacheEntriesReceived(int entriesCnt) Callback for received entries from receiver hub.
void	onSenderCacheBatchAcknowledged(int entriesCnt) Callback for received acknowledgement by sender hub.
void	onSenderCacheBatchFailed(int entriesCnt) Callback for received batch error by sender hub.
void	onSenderCacheBatchSent(int entriesCnt) Callback for sent batch on sender cache side.
void	onSenderCacheEntryFiltered() Callback for filtered entries on sender cache side.
void	onTxCommit() Transaction commit callback.
void	onTxRollback() Transaction rollback callback.
void	onWrite() Cache write callback.
void	readExternal(ObjectInput in)
int	reads() Gets total number of reads of the owning entity (either cache or entry).
long	readTime() Gets last read time of the owning entity (either cache or entry).
long	rollbackTime() Gets last time transaction was rollback.
String	toString()
int	txCommits() Gets total number of transaction commits.
int	txRollbacks() Gets total number of transaction rollbacks.
void	writeExternal(ObjectOutput out)
int	writes() Gets total number of writes of the owning entity (either cache or entry).
long	writeTime() Gets last write time of the owning entity (either cache or entry).

Methods inherited from class java.lang.Object

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

Constructor Detail

GridCacheMetricsAdapter

public GridCacheMetricsAdapter()

No-args constructor.

GridCacheMetricsAdapter

public GridCacheMetricsAdapter(boolean isDrSndCache,
                       boolean isDrRcvCache)

Parameters:

isDrSndCache - True if data center replication configured for sending on that node.

isDrRcvCache - True if data center replication configured for receiving on that node.

GridCacheMetricsAdapter

public GridCacheMetricsAdapter(GridCacheMetrics m)

Parameters:

m - Metrics to copy from.

Method Detail

delegate

public void delegate(GridCacheMetricsAdapter delegate)

Parameters:

delegate - Metrics to delegate to.

createTime

public long createTime()

Gets create time of the owning entity (either cache or entry).

Specified by:

createTime in interface GridCacheMetrics

Returns:

Create time.

writeTime

public long writeTime()

Gets last write time of the owning entity (either cache or entry).

Specified by:

writeTime in interface GridCacheMetrics

Returns:

Last write time.

readTime

public long readTime()

Gets last read time of the owning entity (either cache or entry).

Specified by:

readTime in interface GridCacheMetrics

Returns:

Last read time.

commitTime

public long commitTime()

Gets last time transaction was committed.

Specified by:

commitTime in interface GridCacheMetrics

Returns:

Last commit time.

rollbackTime

public long rollbackTime()

Gets last time transaction was rollback.

Specified by:

rollbackTime in interface GridCacheMetrics

Returns:

Last rollback time.

reads

public int reads()

Gets total number of reads of the owning entity (either cache or entry).

Specified by:

reads in interface GridCacheMetrics

Returns:

Total number of reads.

writes

public int writes()

Gets total number of writes of the owning entity (either cache or entry).

Specified by:

writes in interface GridCacheMetrics

Returns:

Total number of writes.

hits

public int hits()

Gets total number of hits for the owning entity (either cache or entry).

Specified by:

hits in interface GridCacheMetrics

Returns:

Number of hits.

misses

public int misses()

Gets total number of misses for the owning entity (either cache or entry).

Specified by:

misses in interface GridCacheMetrics

Returns:

Number of misses.

txCommits

public int txCommits()

Gets total number of transaction commits.

Specified by:

txCommits in interface GridCacheMetrics

Returns:

Number of transaction commits.

txRollbacks

public int txRollbacks()

Gets total number of transaction rollbacks.

Specified by:

txRollbacks in interface GridCacheMetrics

Returns:

Number of transaction rollbacks.

drSendMetrics

public GridDrSenderCacheMetrics drSendMetrics()

Gets metrics for data sent during data center replication, if data center replication is not configured then IllegalStateException will be thrown.

Specified by:

drSendMetrics in interface GridCacheMetrics

Returns:

Metrics for data sent during data center replication.

drReceiveMetrics

public GridDrReceiverCacheMetrics drReceiveMetrics()

Gets metrics for data received during data center replication, if data center replication is not configured then IllegalStateException will be thrown.

Specified by:

drReceiveMetrics in interface GridCacheMetrics

Returns:

Metrics for data received during data center replication.

onRead

public void onRead(boolean isHit)

Cache read callback.

Parameters:

isHit - Hit or miss flag.

onWrite

public void onWrite()

Cache write callback.

onTxCommit

public void onTxCommit()

Transaction commit callback.

onTxRollback

public void onTxRollback()

Transaction rollback callback.

onSenderCacheBatchAcknowledged

public void onSenderCacheBatchAcknowledged(int entriesCnt)

Callback for received acknowledgement by sender hub.

Parameters:

entriesCnt - Number of entries in batch.

onSenderCacheBatchFailed

public void onSenderCacheBatchFailed(int entriesCnt)

Callback for received batch error by sender hub.

Parameters:

entriesCnt - Number of entries in batch.

onSenderCacheBatchSent

public void onSenderCacheBatchSent(int entriesCnt)

Callback for sent batch on sender cache side.

Parameters:

entriesCnt - Number of sent entries.

onSenderCacheEntryFiltered

public void onSenderCacheEntryFiltered()

Callback for filtered entries on sender cache side.

onPauseStateChanged

public void onPauseStateChanged(@Nullable
                       GridDrPauseReason pauseReason,
                       @Nullable
                       String errMsg)

Callback for replication pause state changed.

Parameters:

pauseReason - Pause reason or null if replication is not paused.

errMsg - Error message.

onReceiveCacheConflictResolved

public void onReceiveCacheConflictResolved(boolean usedNew,
                                  boolean usedOld,
                                  boolean usedMerge)

Callback for conflict resolver on receiver cache side.

Parameters:

usedNew - New conflict status flag.

usedOld - Old conflict status flag.

usedMerge - Merge conflict status flag.

onReceiveCacheEntriesReceived

public void onReceiveCacheEntriesReceived(int entriesCnt)

Callback for received entries from receiver hub.

Parameters:

entriesCnt - Number of received entries.

copyOf

@Nullable
public static GridCacheMetricsAdapter copyOf(@Nullable
                                      GridCacheMetrics m)

Create a copy of given metrics object.

Parameters:

m - Metrics to copy from.

Returns:

Copy of given metrics.

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

toString

public String toString()

Overrides:

toString in class Object