org.gridgain.grid.dr.store

Interface DrSenderStore

All Known Implementing Classes:

DrAbstractSenderStore, DrSenderFsStore, DrSenderInMemoryStore

public interface DrSenderStore

Data center replication sender hub store. Persists batches received from data nodes until they are successfully sent to receiver hub.

Gridgain provides the following GridDrStore implementations:

• DrSenderInMemoryStore
• DrSenderFsStore

Method Summary

Modifier and Type	Method and Description
void	clear() Removes all data from store and resets overflow flag to false.
DrSenderStoreCursor	cursor(byte dataCenterId) Gets cursor for the given data center ID.
boolean	isOverflow() Get overflow state of the store.
long	sizeBytes()
default void	store(byte[] dataCenterIds, byte[] data, int cnt) Store data.
default void	store(byte[] dataCenterIds, byte[] data, int cnt, @Nullable IgniteUuid fstId) Deprecated. Synchronous state transfer uses dedicated FST buffer.

Method Detail

store

@Deprecated
default void store(byte[] dataCenterIds,
                               byte[] data,
                               int cnt,
                               @Nullable
                               @Nullable IgniteUuid fstId)
                        throws IgniteCheckedException,
                               DrSenderStoreOverflowException

Deprecated. Synchronous state transfer uses dedicated FST buffer.

Store data.

Parameters:

dataCenterIds - Target data center ids.

data - Data center replication store entry.

cnt - How many entries are inside passed byte array.

fstId - Full state transfer id.

Throws:

DrSenderStoreOverflowException - If store is overflowed.

IgniteCheckedException - In case of failure.

store

default void store(byte[] dataCenterIds,
                   byte[] data,
                   int cnt)
            throws IgniteCheckedException

Store data.

Parameters:

dataCenterIds - Target data center ids.

data - Data center replication store entry.

cnt - How many entries are inside passed byte array.

Throws:

IgniteCheckedException - In case of failure.

cursor

DrSenderStoreCursor cursor(byte dataCenterId)
                    throws IgniteCheckedException

Gets cursor for the given data center ID.

Parameters:

dataCenterId - Data center ID.

Returns:

Cursor over stored entries which belongs to that data center ID.

Throws:

IgniteCheckedException - If failed.

clear

void clear()
    throws IgniteCheckedException

Removes all data from store and resets overflow flag to false.

Throws:

IgniteCheckedException - If failed.

isOverflow

boolean isOverflow()

Get overflow state of the store. Overflow means that some data lost.

Returns:

True if store is overflowed.

sizeBytes

long sizeBytes()

Returns:

Store size in bytes.