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

Interface GridCacheDrManager<K,V>

All Superinterfaces:

GridCacheManager<K,V>

All Known Implementing Classes:

GridOsCacheDrManager

public interface GridCacheDrManager<K,V>
extends GridCacheManager<K,V>

Replication manager class which processes all replication events.

Method Summary

Methods

Modifier and Type	Method and Description
int	backupQueueSize()
int	batchWaitingAcknowledgeCount()
int	batchWaitingSendCount()
void	beforeExchange(long topVer, boolean left) Process partitions "before exchange" event.
GridDrStatus	drPauseState() Get DR pause state.
Collection<GridDrStateTransferDescriptor>	listStateTransfers() List currently active state transfers.
void	partitionEvicted(int part) In case some partition is evicted, we remove entries of this partition from backup queue.
void	pause() Pauses data center replication.
int	queuedKeysCount()
void	replicate(GridDrRawEntry<K,V> entry, GridDrType drType) Perform replication.
void	resume() Resumes data center replication.
int	senderHubsCount()
GridFuture<?>	stateTransfer(Collection<Byte> dataCenterIds) Initiate state transfer.

Methods inherited from interface org.gridgain.grid.kernal.processors.cache.GridCacheManager

onKernalStart, onKernalStop, printMemoryStats, start, stop

Method Detail

replicate

void replicate(GridDrRawEntry<K,V> entry,
             GridDrType drType)

Perform replication.

Parameters:

entry - Replication entry.

drType - Replication type.

beforeExchange

void beforeExchange(long topVer,
                  boolean left)
                    throws GridException

Process partitions "before exchange" event.

Parameters:

topVer - Topology version.

left - True if exchange has been caused by node leave.

Throws:

GridException - If failed.

partitionEvicted

void partitionEvicted(int part)

In case some partition is evicted, we remove entries of this partition from backup queue.

Parameters:

part - Partition.

stateTransfer

GridFuture<?> stateTransfer(Collection<Byte> dataCenterIds)

Initiate state transfer.

Parameters:

dataCenterIds - Target data center IDs.

Returns:

Future that will be completed when all state transfer batches are sent.

listStateTransfers

Collection<GridDrStateTransferDescriptor> listStateTransfers()
                                                             throws GridException

List currently active state transfers.

Returns:

List of currently active state transfers.

Throws:

GridException - If failed.

pause

void pause()
           throws GridException

Pauses data center replication.

Throws:

GridException - If failed.

resume

void resume()
            throws GridException

Resumes data center replication.

Throws:

GridException - If failed.

drPauseState

GridDrStatus drPauseState()

Get DR pause state.

Returns:

DR pause state.

queuedKeysCount

int queuedKeysCount()

Returns:

Count of keys enqueued for data center replication.

backupQueueSize

int backupQueueSize()

Returns:

Size of backup data center replication queue.

batchWaitingSendCount

int batchWaitingSendCount()

Returns:

Count of data center replication batches awaiting to be send.

batchWaitingAcknowledgeCount

int batchWaitingAcknowledgeCount()

Returns:

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

senderHubsCount

int senderHubsCount()

Returns:

Count of available sender hubs.