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

Class GridDrSenderCacheMetricsAdapter

java.lang.Object

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

All Implemented Interfaces:

Externalizable, Serializable, GridDrSenderCacheMetrics

public class GridDrSenderCacheMetricsAdapter
extends Object
implements GridDrSenderCacheMetrics, Externalizable

Adapter for DR send data node metrics.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GridDrSenderCacheMetricsAdapter() No-args constructor.

Method Summary

Methods

Modifier and Type	Method and Description
long	backupQueueSize() Gets current amount of cache entries in backup queue.
void	backupQueueSize(int backupQueueSize) Callback for backup queue size changed.
int	batchesAcked() Gets total amount of sent batches acknowledged by sender hub.
int	batchesFailed() Gets total amount of failed batches.
int	batchesSent() Gets total amount of batches sent to sender hubs.
static GridDrSenderCacheMetricsAdapter	copyOf(GridDrSenderCacheMetrics m) Create a copy of given metrics object.
long	entriesAcked() Gets total amount of sent entries acknowledged by sender hub.
long	entriesFiltered() Gets total amount of filtered cache entries.
long	entriesSent() Gets total amount of entries sent to sender hubs.
void	onBatchAcked(int entriesCnt) Callback for received successful batch acknowledgement by sender hub.
void	onBatchFailed(int entriesCnt) Callback for received batch error by sender hub.
void	onBatchSent(int entriesCnt) Callback for sent batch on sender cache side.
void	onEntryFiltered() Callback for filtered entries on sender cache side.
void	onPauseStateChanged(GridDrPauseReason pauseReason, String errMsg) Callback for replication pause state changed.
void	readExternal(ObjectInput in)
GridDrStatus	status() Gets data center replication status.
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

GridDrSenderCacheMetricsAdapter

public GridDrSenderCacheMetricsAdapter()

No-args constructor.

Method Detail

batchesSent

public int batchesSent()

Gets total amount of batches sent to sender hubs.

Specified by:

batchesSent in interface GridDrSenderCacheMetrics

Returns:

Total amount of batches sent to sender hubs.

entriesSent

public long entriesSent()

Gets total amount of entries sent to sender hubs.

Specified by:

entriesSent in interface GridDrSenderCacheMetrics

Returns:

Total amount of entries sent to sender hubs.

entriesFiltered

public long entriesFiltered()

Gets total amount of filtered cache entries. Data center replication provides ability to filter entries before being replicated to another data center (see GridDrSenderCacheConfiguration.getEntryFilter()). This metric returns the number of entries that didn't pass that filter.

Specified by:

entriesFiltered in interface GridDrSenderCacheMetrics

Returns:

Total amount of filtered cache entries.

batchesAcked

public int batchesAcked()

Gets total amount of sent batches acknowledged by sender hub.

Specified by:

batchesAcked in interface GridDrSenderCacheMetrics

Returns:

Total amount of sent batches acknowledged by sender hub.

entriesAcked

public long entriesAcked()

Gets total amount of sent entries acknowledged by sender hub.

Specified by:

entriesAcked in interface GridDrSenderCacheMetrics

Returns:

Total amount of sent entries acknowledged by sender hub.

batchesFailed

public int batchesFailed()

Gets total amount of failed batches. Failure may occur because there was no available sender hubs during batch send or sender hub replied with an error.

Specified by:

batchesFailed in interface GridDrSenderCacheMetrics

Returns:

Total amount of failed batches.

backupQueueSize

public long backupQueueSize()

Gets current amount of cache entries in backup queue.

Specified by:

backupQueueSize in interface GridDrSenderCacheMetrics

Returns:

Current amount of cache entries in backup queue.

status

@Nullable
public GridDrStatus status()

Gets data center replication status.

Specified by:

status in interface GridDrSenderCacheMetrics

Returns:

Data center replication status.

onBatchAcked

public void onBatchAcked(int entriesCnt)

Callback for received successful batch acknowledgement by sender hub.

Parameters:

entriesCnt - Number of entries in batch.

onBatchFailed

public void onBatchFailed(int entriesCnt)

Callback for received batch error by sender hub.

Parameters:

entriesCnt - Number of entries in batch.

onBatchSent

public void onBatchSent(int entriesCnt)

Callback for sent batch on sender cache side.

Parameters:

entriesCnt - Number of sent entries.

onEntryFiltered

public void onEntryFiltered()

Callback for filtered entries on sender cache side.

backupQueueSize

public void backupQueueSize(int backupQueueSize)

Callback for backup queue size changed.

Parameters:

backupQueueSize - Size of sender cache backup queue.

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.

copyOf

@Nullable
public static GridDrSenderCacheMetricsAdapter copyOf(@Nullable
                                              GridDrSenderCacheMetrics 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