org.gridgain.grid.dr

Interface DrSender

public interface DrSender

Data center replication sender interface.

This interface provides methods for monitoring states of data center connections, like connection status, store overflow status, etc.

Method Summary

Modifier and Type	Method and Description
void	clearFullStateTransferBuffer() Clear full state transfer buffer.
void	clearGlobalStore() Clear global sender store if it is configured.
DrSenderConnection	connection(byte dcId) Get connection to remote data center with provided ID.
Collection<DrSenderConnection>	connections() Get all connections to remote data centers configured for this sender.
DrSenderConfiguration	getConfiguration() Get sender configuration.
boolean	hasConnection(byte dcId) Check whether sender has configured connection to remote data center with provided ID.
boolean	isGlobalStore() Check whether configured DR store is global and is shared between all connections.
void	pause() Pause replication to all remote DCs.
void	pause(byte dcId) Pause replication for given DC.
boolean	paused(byte dcId) Returns DC pause flag.
void	resume() Resume replication for all remote DCs.
void	resume(byte dcId) Resume replication for given DC.

Method Detail

pause

void pause()

Pause replication to all remote DCs.

resume

void resume()

Resume replication for all remote DCs.

pause

void pause(byte dcId)

Pause replication for given DC.

Parameters:

dcId - Remote data center id.

paused

boolean paused(byte dcId)

Returns DC pause flag.

Parameters:

dcId - Remote data center id.

Returns:

true if given DC was paused.

resume

void resume(byte dcId)

Resume replication for given DC.

Parameters:

dcId - Remote data center id.

connections

Collection<DrSenderConnection> connections()

Get all connections to remote data centers configured for this sender.

Returns:

Connections to remote data centers.

hasConnection

boolean hasConnection(byte dcId)

Check whether sender has configured connection to remote data center with provided ID.

Parameters:

dcId - Data center ID.

Returns:

True if connection is configured.

connection

DrSenderConnection connection(byte dcId)
                       throws IllegalStateException

Get connection to remote data center with provided ID.

Parameters:

dcId - Data center ID of requested replica.

Returns:

Connection to specified remote data center.

Throws:

IllegalStateException - If sender is not configured to work with remote data center with provided ID.

getConfiguration

DrSenderConfiguration getConfiguration()

Get sender configuration.

Returns:

Sender configuration.

isGlobalStore

boolean isGlobalStore()

Check whether configured DR store is global and is shared between all connections.

Returns:

True if store is global.

clearGlobalStore

void clearGlobalStore()

Clear global sender store if it is configured. All pending updates which are not sent to the remote DC are cleared too.

Throws:

IllegalStateException - If global is store is not configured.

clearFullStateTransferBuffer

void clearFullStateTransferBuffer()

Clear full state transfer buffer.