org.gridgain.grid.cache.dr

Interface CacheDrSenderMetrics

public interface CacheDrSenderMetrics

Metrics for data center replication sender cache.

Method Summary

Modifier and Type	Method and Description
long	backupQueueSize() Gets current amount of cache entries in backup queue.
int	batchesAcked() Gets total amount of sent batches acknowledged by sender hub.
int	batchesFailed() Gets total amount of failed batches.
int	batchesRejected() Gets total amount of rejected batches due to backpressure or any recoverable error.
int	batchesSent() Gets total amount of batches sent to sender hubs.
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.
long	fstThrottlingMilliseconds() Gets current amount of milliseconds the node waited during full state transfer due to load throttling.
long	pendingQueueSize() Gets current amount of cache entries in pending queue.
CacheDrStatus	status() Gets data center replication status.

Method Detail

batchesSent

int batchesSent()

Gets total amount of batches sent to sender hubs.

Returns:

Total amount of batches sent to sender hubs.

entriesSent

long entriesSent()

Gets total amount of entries sent to sender hubs.

Returns:

Total amount of entries sent to sender hubs.

batchesAcked

int batchesAcked()

Gets total amount of sent batches acknowledged by sender hub.

Returns:

Total amount of sent batches acknowledged by sender hub.

entriesAcked

long entriesAcked()

Gets total amount of sent entries acknowledged by sender hub.

Returns:

Total amount of sent entries acknowledged by sender hub.

batchesFailed

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.

Returns:

Total amount of failed batches.

batchesRejected

int batchesRejected()

Gets total amount of rejected batches due to backpressure or any recoverable error.

Returns:

Total amount of rejected batches.

entriesFiltered

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 CacheDrSenderConfiguration.getEntryFilter()). This metric returns the number of entries that didn't pass that filter.

Returns:

Total amount of filtered cache entries.

backupQueueSize

long backupQueueSize()

Gets current amount of cache entries in backup queue.

Returns:

Current amount of cache entries in backup queue.

pendingQueueSize

long pendingQueueSize()

Gets current amount of cache entries in pending queue.

Returns:

Current amount of cache entries in pending queue.

fstThrottlingMilliseconds

long fstThrottlingMilliseconds()

Gets current amount of milliseconds the node waited during full state transfer due to load throttling.

Returns:

Current amount of milliseconds the node waited during full state transfer due to load throttling.

status

CacheDrStatus status()

Gets data center replication status.

Returns:

Data center replication status.