org.gridgain.grid.dr.cache.sender

Class GridDrSenderCacheConfiguration

java.lang.Object

org.gridgain.grid.dr.cache.sender.GridDrSenderCacheConfiguration

public class GridDrSenderCacheConfiguration
extends Object

Data center replication sender cache configuration.

Field Summary

Fields

Modifier and Type	Field and Description
static long	DFLT_BATCH_SND_FREQUENCY Default data center replication sender cache batch send frequency.
static int	DFLT_BATCH_SND_SIZE Default data center replication sender cache batch send size.
static int	DFLT_MAX_BATCHES Default data center replication sender cache maximum amount of pending batches.
static GridDrSenderCacheMode	DFLT_MODE Default data center replication sender cache mode.
static GridDrSenderHubLoadBalancingMode	DFLT_SND_HUB_LOAD_BALANCING_MODE Default data center replication sender cache sender hub load balancing mode.
static int	DFLT_STATE_TRANSFER_THREADS_CNT Default data center replication sender cache amount of worker threads responsible for full state transfer.
static long	DFLT_STATE_TRANSFER_THROTTLE Default data center replication sender cache state transfer throttle.

Constructor Summary

Constructors

Constructor and Description
GridDrSenderCacheConfiguration() Default constructor.
GridDrSenderCacheConfiguration(GridDrSenderCacheConfiguration cfg) Copying constructor.

Method Summary

Methods

Modifier and Type	Method and Description
long	getBatchSendFrequency() Gets batch send frequency.
int	getBatchSendSize() Gets batch send size.
GridDrSenderCacheEntryFilter	getEntryFilter() Gets entry filter.
int	getMaxBatches() Gets maximum amount of batches awaiting for sender hub acknowledge.
GridDrSenderCacheMode	getMode() Gets mode.
GridDrSenderHubLoadBalancingMode	getSenderHubLoadBalancingMode() Gets sender hub load balancing mode.
int	getStateTransferThreadsCount() Gets state transfer threads count.
long	getStateTransferThrottle() Gets state transfer throttle.
void	setBatchSendFrequency(long batchSndFreq) Sets batch send frequency.
void	setBatchSendSize(int batchSndSize) Sets batch send size.
void	setEntryFilter(GridDrSenderCacheEntryFilter entryFilter) Set entry filter.
void	setMaxBatches(int maxBatches) Sets maximum amount of batches awaiting for sender hub acknowledge.
void	setMode(GridDrSenderCacheMode mode) Sets mode.
void	setSenderHubLoadBalancingMode(GridDrSenderHubLoadBalancingMode sndHubLoadBalancingMode) Sets sender hub load balancing mode.
void	setStateTransferThreadsCount(int stateTransferThreadsCnt) Sets state transfer threads count.
void	setStateTransferThrottle(long stateTransferThrottle) Sets state transfer throttle.
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

DFLT_MODE

public static final GridDrSenderCacheMode DFLT_MODE

Default data center replication sender cache mode.

DFLT_BATCH_SND_FREQUENCY

public static final long DFLT_BATCH_SND_FREQUENCY

Default data center replication sender cache batch send frequency.

See Also:

Constant Field Values

DFLT_BATCH_SND_SIZE

public static final int DFLT_BATCH_SND_SIZE

Default data center replication sender cache batch send size.

See Also:

Constant Field Values

DFLT_MAX_BATCHES

public static final int DFLT_MAX_BATCHES

Default data center replication sender cache maximum amount of pending batches.

See Also:

Constant Field Values

DFLT_SND_HUB_LOAD_BALANCING_MODE

public static final GridDrSenderHubLoadBalancingMode DFLT_SND_HUB_LOAD_BALANCING_MODE

Default data center replication sender cache sender hub load balancing mode.

DFLT_STATE_TRANSFER_THREADS_CNT

public static final int DFLT_STATE_TRANSFER_THREADS_CNT

Default data center replication sender cache amount of worker threads responsible for full state transfer.

See Also:

Constant Field Values

DFLT_STATE_TRANSFER_THROTTLE

public static final long DFLT_STATE_TRANSFER_THROTTLE

Default data center replication sender cache state transfer throttle.

See Also:

Constant Field Values

Constructor Detail

GridDrSenderCacheConfiguration

public GridDrSenderCacheConfiguration()

Default constructor.

GridDrSenderCacheConfiguration

public GridDrSenderCacheConfiguration(GridDrSenderCacheConfiguration cfg)

Copying constructor.

Parameters:

cfg - Configuration to copy.

Method Detail

getMode

@Nullable
public GridDrSenderCacheMode getMode()

Gets mode. See GridDrSenderCacheMode for more info.

Defaults to DFLT_MODE.

Returns:

Mode.

setMode

public void setMode(GridDrSenderCacheMode mode)

Sets mode. See getMode() for more information.

Parameters:

mode - Mode.

getBatchSendSize

public int getBatchSendSize()

Gets batch send size. When size of a batch is greater than the given value or it's lifetime is greater than getBatchSendFrequency() batch will be sent to a sender hub.

When set to non-positive value, batch will be sent only in case it's lifetime is greater than getBatchSendFrequency().

Defaults to DFLT_BATCH_SND_SIZE.

Returns:

Batch send size.

setBatchSendSize

public void setBatchSendSize(int batchSndSize)

Sets batch send size. See getBatchSendSize() for more information.

Parameters:

batchSndSize - Batch send size.

getBatchSendFrequency

public long getBatchSendFrequency()

Gets batch send frequency. When size of a batch is greater than getBatchSendSize() or it's lifetime is greater than the given value batch will be sent to a sender hub.

When set to non-positive value, batch will be sent only in case it's size is greater than #getBatchSendSize().

Defaults to DFLT_BATCH_SND_FREQUENCY.

Returns:

Batch send frequency.

setBatchSendFrequency

public void setBatchSendFrequency(long batchSndFreq)

Sets batch send frequency. See getBatchSendFrequency() for more information.

Parameters:

batchSndFreq - Batch send frequency.

getMaxBatches

public int getMaxBatches()

Gets maximum amount of batches awaiting for sender hub acknowledge. When amount of batches awaiting sender hub delivery acknowledge reaches this value, all further cache updates will be suspended until it is below the limit again.

When set to non-positive value, maximum amount of batches is unlimited.

Defaults to DFLT_MAX_BATCHES.

Returns:

Maximum amount of batches awaiting for sender hub acknowledge.

setMaxBatches

public void setMaxBatches(int maxBatches)

Sets maximum amount of batches awaiting for sender hub acknowledge. See getMaxBatches() for more information.

Parameters:

maxBatches - Maximum amount of batches awaiting for sender hub acknowledge.

getEntryFilter

public GridDrSenderCacheEntryFilter getEntryFilter()

Gets entry filter. When set it will be applied to all entries which are candidates for data center replication. If the filter is not passed, data center replication will not be performed on that entry.*

Defaults to null.

Returns:

Entry filter.

setEntryFilter

public void setEntryFilter(@Nullable
                  GridDrSenderCacheEntryFilter entryFilter)

Set entry filter. See getEntryFilter() for more information.

Parameters:

entryFilter - Entry filter.

getSenderHubLoadBalancingMode

public GridDrSenderHubLoadBalancingMode getSenderHubLoadBalancingMode()

Gets sender hub load balancing mode. When batch is ready to be sent, this parameter defines how to select the next sender hub this batch will be sent to.

Defaults to DFLT_SND_HUB_LOAD_BALANCING_MODE.

Returns:

Sender hub load balancing mode.

setSenderHubLoadBalancingMode

public void setSenderHubLoadBalancingMode(GridDrSenderHubLoadBalancingMode sndHubLoadBalancingMode)

Sets sender hub load balancing mode. See getSenderHubLoadBalancingMode() for more information.

Parameters:

sndHubLoadBalancingMode - Sender hub load balancing mode.

getStateTransferThrottle

public long getStateTransferThrottle()

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

When set to 0 throttling is disabled.

Defaults to DFLT_STATE_TRANSFER_THROTTLE.

Returns:

State transfer throttle.

setStateTransferThrottle

public void setStateTransferThrottle(long stateTransferThrottle)

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

Parameters:

stateTransferThrottle - State transfer throttle.

getStateTransferThreadsCount

public int getStateTransferThreadsCount()

Gets state transfer threads count. Defines amount of threads which will iterate over cache and force entries data center replication.

Defaults to DFLT_STATE_TRANSFER_THREADS_CNT.

Returns:

State transfer threads count

setStateTransferThreadsCount

public void setStateTransferThreadsCount(int stateTransferThreadsCnt)

Sets state transfer threads count. See getStateTransferThreadsCount() for more information.

Parameters:

stateTransferThreadsCnt - State transfer threads count

toString

public String toString()

Overrides:

toString in class Object