Package com.gigaspaces.internal.cluster.node.impl.packets.data

Interface IReplicationPacketDataConsumer<T extends IReplicationPacketData<?>>

All Known Subinterfaces:

IReplicationPacketDataBatchConsumer<T>

All Known Implementing Classes:

BlobstoreReplicationPacketDataConsumer, ReplicationPacketDataConsumer

public interface IReplicationPacketDataConsumer<T extends IReplicationPacketData<?>>

Consumes IReplicationPacketData and delegate it to the corresponding replication in handler.

Since:

8.0

Author:

eitany

Method Summary

Modifier and Type	Method	Description
T	applyFix(IReplicationInContext context, T data, IDataConsumeFix fix)	Apply a fix to a data, the fix is generated due to a failed consumption of IReplicationPacketData
IDataConsumeResult	consume(IReplicationInContext context, T data, IReplicationInFacade replicationInFacade, IReplicationInFilterCallback filterInCallback)	Consumes a IReplicationPacketData and delegate the operation is represents to the corresponding method at the given IReplicationInFacade
IReplicationParticipantsMetadata	extractParticipantsMetadata(IReplicationPacketData<?> data)	Extracts participants meta data for the provided replication packet data
SpaceTypeManager	getTypeManager()
IReplicationPacketData<?>	merge(IReplicationPacketData<?>[] allParticipantsData, IReplicationParticipantsMetadata participantsMetadata)	Merges data of multiple participants operations to a single operation data which will eventually be executed as one.
Iterable<IReplicationFilterEntry>	toFilterEntries(IReplicationInContext context, IReplicationPacketData<?> data)	Transform generated data to filter entry in order to be passed to a filter

Method Details

consume

IDataConsumeResult consume(IReplicationInContext context,
 T data,
 IReplicationInFacade replicationInFacade,
 IReplicationInFilterCallback filterInCallback)

Consumes a IReplicationPacketData and delegate the operation is represents to the corresponding method at the given IReplicationInFacade

Parameters:

data - operation to consume and translate to an operation

replicationInFacade - facade to delegate the data as incoming replication

Returns:

consumption result that indicates success consumption or error

applyFix

T applyFix(IReplicationInContext context,
 T data,
 IDataConsumeFix fix)
    throws Exception

Apply a fix to a data, the fix is generated due to a failed consumption of IReplicationPacketData

Parameters:

data - data to fix

fix - fix to apply

Returns:

fixed data

Throws:

Exception

toFilterEntries

Iterable<IReplicationFilterEntry> toFilterEntries(IReplicationInContext context,
 IReplicationPacketData<?> data)

Transform generated data to filter entry in order to be passed to a filter

Returns:

collection of replication filter entries representing the data

extractParticipantsMetadata

IReplicationParticipantsMetadata extractParticipantsMetadata(IReplicationPacketData<?> data)

Extracts participants meta data for the provided replication packet data

merge

IReplicationPacketData<?> merge(IReplicationPacketData<?>[] allParticipantsData,
 IReplicationParticipantsMetadata participantsMetadata)

Merges data of multiple participants operations to a single operation data which will eventually be executed as one.

Parameters:

participantsMetadata - TODO

getTypeManager

SpaceTypeManager getTypeManager()