org.gridgain.grid.kernal.processors.cache.dr

Class GridDrReceiverCacheMetricsAdapter

java.lang.Object

org.gridgain.grid.kernal.processors.cache.dr.GridDrReceiverCacheMetricsAdapter

All Implemented Interfaces:

Externalizable, Serializable, GridDrReceiverCacheMetrics

public class GridDrReceiverCacheMetricsAdapter
extends Object
implements GridDrReceiverCacheMetrics, Externalizable

Adapter for DR receive data node metrics.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GridDrReceiverCacheMetricsAdapter() No-args constructor.

Method Summary

Methods

Modifier and Type	Method and Description
long	conflictMerge() Gets total amount of conflicts resolved by merge.
long	conflictNew() Gets total amount of conflicts resolved by using new value.
long	conflictOld() Gets total amount of conflicts resolved by using old value.
static GridDrReceiverCacheMetricsAdapter	copyOf(GridDrReceiverCacheMetrics m) Create a copy of given metrics object.
long	entriesReceived() Gets total amount of cache entries received from receiver hub.
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	readExternal(ObjectInput in)
String	toString()
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

GridDrReceiverCacheMetricsAdapter

public GridDrReceiverCacheMetricsAdapter()

No-args constructor.

Method Detail

entriesReceived

public long entriesReceived()

Gets total amount of cache entries received from receiver hub.

Specified by:

entriesReceived in interface GridDrReceiverCacheMetrics

Returns:

Total amount of cache entries received from receiver hub.

conflictNew

public long conflictNew()

Gets total amount of conflicts resolved by using new value. See GridDrReceiverCacheConflictContext.useNew() for more info.

Specified by:

conflictNew in interface GridDrReceiverCacheMetrics

Returns:

Total amount of conflicts resolved by using new value.

conflictOld

public long conflictOld()

Gets total amount of conflicts resolved by using old value. See GridDrReceiverCacheConflictContext.useOld() for more info.

Specified by:

conflictOld in interface GridDrReceiverCacheMetrics

Returns:

Total amount of conflicts resolved by using old value.

conflictMerge

public long conflictMerge()

Gets total amount of conflicts resolved by merge. See GridDrReceiverCacheConflictContext.merge(Object, long) for more info.

Specified by:

conflictMerge in interface GridDrReceiverCacheMetrics

Returns:

Total amount of conflicts resolved by merge.

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 GridDrReceiverCacheMetricsAdapter copyOf(@Nullable
                                                GridDrReceiverCacheMetrics 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