org.gridgain.grid.cache.dr

Interface CacheDrMBean

public interface CacheDrMBean

This interface defines JMX view on cache data center replication.

Method Summary

Modifier and Type	Method and Description
void	disableAdaptiveThrottling() Disables adaptive DR throttling.
void	enableAdaptiveThrottling() Enables adaptive DR throttling.
int	getDrBackupQueueSize() Gets size of data center replication backup queue.
int	getDrBatchWaitingAcknowledgeCount() Gets count of data center replication batches awaiting acknowledge from sender hub.
int	getDrBatchWaitingSendCount() Gets count of data center replication batches awaiting to be send.
int	getDrQueuedKeysCount() Gets count of keys enqueued for data center replication.
String	getDrSenderGroup() Gets sender group for this cache.
int	getDrSenderHubsCount() Gets count of available data center replication sender hubs.
String	getDrStatus() Gets current status of data center replication.
long	getStateTransferThrottle() Gets state transfer throttle.
void	pause() Pauses data center replication for this cache.
void	resume() Starts data center replication for this cache.
void	setStateTransferThrottle(long stateTransferThrottle) Sets state transfer throttle.
void	start() Starts data center replication for this cache.
void	stop() Stops data center replication for this cache.
void	transferTo(byte dataCenterId) Performs full state data transfer of this cache to the specified data center.

Method Detail

getDrQueuedKeysCount

@MXBeanDescription(value="Count of keys enqueued for data center replication.")
int getDrQueuedKeysCount()

Gets count of keys enqueued for data center replication.

Returns:

Count of keys enqueued for data center replication.

getDrBackupQueueSize

@MXBeanDescription(value="Size of data center replication backup queue.")
int getDrBackupQueueSize()

Gets size of data center replication backup queue.

Returns:

Size of data center replication backup queue.

getDrBatchWaitingSendCount

@MXBeanDescription(value="Count of data center replication batches awaiting to be send.")
int getDrBatchWaitingSendCount()

Gets count of data center replication batches awaiting to be send.

Returns:

Count of data center replication batches awaiting to be send.

getDrBatchWaitingAcknowledgeCount

@MXBeanDescription(value="Count of data center replication batches awaiting acknowledge from sender hub.")
int getDrBatchWaitingAcknowledgeCount()

Gets count of data center replication batches awaiting acknowledge from sender hub.

Returns:

Count of data center replication batches awaiting acknowledge from sender hub.

getDrSenderHubsCount

@MXBeanDescription(value="Count of available data center replication sender hubs.")
int getDrSenderHubsCount()

Gets count of available data center replication sender hubs.

Returns:

Count of available data center replication sender hubs.

getDrSenderGroup

@MXBeanDescription(value="Sender group for this cache.")
String getDrSenderGroup()

Gets sender group for this cache.

Returns:

Sender group for this cache.

getDrStatus

@MXBeanDescription(value="Current status of data center replication.")
String getDrStatus()

Gets current status of data center replication.

Returns:

Current status of data center replication.

pause

@MXBeanDescription(value="Pauses data center replication for this cache.")
void pause()

Pauses data center replication for this cache. NOTE: Non-incremental DR will be stopped (see stop()) and full-state transfer may be needed after resume.

resume

@MXBeanDescription(value="Resumes data center replication for this cache.")
void resume()

Starts data center replication for this cache. NOTE: Non-incremental DR will be started (see start()) and further full-state transfer may be needed.

stop

@MXBeanDescription(value="Stops data center replication for this cache.")
void stop()

Stops data center replication for this cache. NOTE: Incremental DR will be paused. See pause().

start

@MXBeanDescription(value="Starts data center replication for this cache.")
void start()

Starts data center replication for this cache. NOTE: Incremental DR will be resumed. See resume().

transferTo

@MXBeanDescription(value="Performs full state data transfer of this cache to the specified data center.")
 @MXBeanParametersNames(value="dataCenterId")
 @MXBeanParametersDescriptions(value="Destination data center id.")
void transferTo(byte dataCenterId)

Performs full state data transfer of this cache to the specified data center.

Parameters:

dataCenterId - Destination data center id.

setStateTransferThrottle

@MXBeanDescription(value="Sets state transfer throttle.")
void setStateTransferThrottle(long stateTransferThrottle)

Sets state transfer throttle. See getStateTransferThrottle() for more information.

Parameters:

stateTransferThrottle - State transfer throttle.

getStateTransferThrottle

@MXBeanDescription(value="Gets state transfer throttle.")
long getStateTransferThrottle()

Gets state transfer throttle. Defines delay in milliseconds to wait between full state transfer batches creation to avoid CPU or network overload.

Returns:

State transfer throttle.

disableAdaptiveThrottling

@MXBeanDescription(value="Disables adaptive DR throttling.")
void disableAdaptiveThrottling()

Disables adaptive DR throttling.

enableAdaptiveThrottling

@MXBeanDescription(value="Enables adaptive DR throttling.")
void enableAdaptiveThrottling()

Enables adaptive DR throttling.