org.gridgain.grid.dr.store.memory

Class DrSenderInMemoryStore

java.lang.Object

org.gridgain.grid.dr.store.DrAbstractSenderStore

org.gridgain.grid.dr.store.memory.DrSenderInMemoryStore

All Implemented Interfaces:

LifecycleAware, DrSenderStore

public class DrSenderInMemoryStore
extends DrAbstractSenderStore
implements LifecycleAware

Data center replication sender hub store implementation which stores data in memory.

Configuration

Mandatory

There are no mandatory configuration parameters.

Optional

The following configuration parameters are optional:

• Maximum number of entries can be stored (see setMaxSize(int))
• Overflow mode defining how store will behave in case of overflow (see setOverflowMode(DrSenderStoreOverflowMode))

See Also:

DrSenderStore

Field Summary

Fields

Modifier and Type	Field and Description
static int	DFLT_MAX_SIZE

Fields inherited from class org.gridgain.grid.dr.store.DrAbstractSenderStore

overflowMode

Constructor Summary

Constructors

Constructor and Description
DrSenderInMemoryStore()

Method Summary

Modifier and Type	Method and Description
void	clear0() Remove all store data and reset store's state.
DrSenderStoreCursor	cursor0(byte dataCenterId) Create new cursor for specified data center.
int	getMaxSize() Gets maximum number of entries can be stored.
DrSenderInMemoryStore	setMaxSize(int maxSize) Sets maximum number of entries can be stored.
DrSenderInMemoryStore	setOverflowMode(DrSenderStoreOverflowMode overflowMode) Sets overflow mode defining how store will behave in case of overflow.
long	sizeBytes()
void	start() Starts grid component, called on grid start.
void	stop() Stops grid component, called on grid shutdown.
void	store0(byte[] dcIds, byte[] data, int cnt, @Nullable IgniteUuid fstId) Add data to store.
String	toString()

Methods inherited from class org.gridgain.grid.dr.store.DrAbstractSenderStore

clear, cursor, getOverflowMode, isOverflow, onOverflow, setOverflowCallback, store

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.gridgain.grid.dr.store.DrSenderStore

store

Field Detail

DFLT_MAX_SIZE

public static final int DFLT_MAX_SIZE

See Also:

Constant Field Values

Constructor Detail

DrSenderInMemoryStore

public DrSenderInMemoryStore()

Method Detail

getMaxSize

public int getMaxSize()

Gets maximum number of entries can be stored. This value should power of two.

Defaults to DFLT_MAX_SIZE.

Returns:

Maximum number of entries in store.

setMaxSize

public DrSenderInMemoryStore setMaxSize(int maxSize)

Sets maximum number of entries can be stored. See getMaxSize() for more information.

Parameters:

maxSize - Maximum number of entries in store.

Returns:

this for chaining.

setOverflowMode

public DrSenderInMemoryStore setOverflowMode(DrSenderStoreOverflowMode overflowMode)

Sets overflow mode defining how store will behave in case of overflow. See DrAbstractSenderStore.getOverflowMode() for more information.

Overrides:

setOverflowMode in class DrAbstractSenderStore

Parameters:

overflowMode - Overflow mode.

Returns:

this for chaining.

start

public void start()

Starts grid component, called on grid start.

Specified by:

start in interface LifecycleAware

stop

public void stop()

Stops grid component, called on grid shutdown.

Specified by:

stop in interface LifecycleAware

store0

public void store0(byte[] dcIds,
                   byte[] data,
                   int cnt,
                   @Nullable
                   @Nullable IgniteUuid fstId)
            throws IgniteCheckedException

Add data to store.

Specified by:

store0 in class DrAbstractSenderStore

Parameters:

dcIds - Data center id.

data - Data to store.

cnt - Entries count.

fstId - Full state transfer id.

Throws:

DrSenderStoreOverflowException - If store is overflowed and mode is DrSenderStoreOverflowMode.STOP.

IgniteCheckedException

cursor0

public DrSenderStoreCursor cursor0(byte dataCenterId)
                            throws IgniteCheckedException

Create new cursor for specified data center.

Specified by:

cursor0 in class DrAbstractSenderStore

Parameters:

dataCenterId - Data center id.

Returns:

New cursor.

Throws:

IgniteCheckedException - If fails.

clear0

public void clear0()
            throws IgniteCheckedException

Remove all store data and reset store's state.

Specified by:

clear0 in class DrAbstractSenderStore

Throws:

IgniteCheckedException - If fails.

sizeBytes

public long sizeBytes()

Specified by:

sizeBytes in interface DrSenderStore

Returns:

Store size in bytes.

toString

public String toString()

Overrides:

toString in class Object