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

Interface IReplicationPacketDataProducer<T extends IReplicationPacketData<?>>

All Superinterfaces:

IReplicationPacketEntryDataContentExtractor

All Known Implementing Classes:

BlobstoreReplicationPacketDataProducer, ReplicationPacketDataProducer

public interface IReplicationPacketDataProducer<T extends IReplicationPacketData<?>>
extends IReplicationPacketEntryDataContentExtractor

Convert logical operation to a representing IReplicationPacketData

Since:

8.0

Author:

eitany

Method Summary

Modifier and Type	Method and Description
void	completePacketDataContent(T data)
T	convertData(T data, ReplicationMultipleOperationType convertToOperation, PlatformLogicalVersion targetMemberVersion) Converts the given data
IReplicationPacketEntryData	convertEntryData(IReplicationPacketEntryData entryData, ReplicationEntryDataConversionMetadata metadata, PlatformLogicalVersion targetMemberVersion) Converts the given entry data to the specified operation
T	convertSingleEntryData(T singleEntryData, ReplicationEntryDataConversionMetadata metadata, PlatformLogicalVersion targetMemberVersion) Convert the given data that has a single entry (IReplicationPacketData.isSingleEntryData() must be true) to the specified operation
T	createEmptyMultipleEntryData(T data) create an empty data of the same type of the given data, this data must not be IReplicationPacketData.isSingleEntryData()
IDataConsumeFix	createFix(IDataConsumeResult errorResult, T errorData) Creates a fix for the given error result, that fixed should be applied at the corresponding IReplicationPacketDataConsumer
T	createGenericOperationData(Object operationData, ReplicationSingleOperationType operationType, ReplicationOutContext entireContext)
T	createSingleOperationData(IEntryHolder entryHolder, ReplicationSingleOperationType operationType, ReplicationOutContext replicationOutContext) Convert a single entry operation to a representing IReplicationPacketData
T	createTransactionOperationData(ServerTransaction transaction, ArrayList<IEntryHolder> lockedEntries, ReplicationOutContext replicationOutContext, ReplicationMultipleOperationType operationType) Convert a transaction operation to a representing IReplicationPacketData
Iterable<IReplicationFilterEntry>	toFilterEntries(T data) Transform generated data to filter entry in order to be passed to a filter

Methods inherited from interface com.gigaspaces.internal.cluster.node.impl.packets.data.IReplicationPacketEntryDataContentExtractor

getCustomContent, getMainEntryData, getMainTypeName, getSecondaryEntryData, requiresConversion, setSerializeWithFullContent

Method Detail

createSingleOperationData

T createSingleOperationData(IEntryHolder entryHolder,
                            ReplicationSingleOperationType operationType,
                            ReplicationOutContext replicationOutContext)

Convert a single entry operation to a representing IReplicationPacketData

Parameters:

entryHolder - operation entry

operationType - operation type

Returns:

representing IReplicationPacketData

createTransactionOperationData

T createTransactionOperationData(ServerTransaction transaction,
                                 ArrayList<IEntryHolder> lockedEntries,
                                 ReplicationOutContext replicationOutContext,
                                 ReplicationMultipleOperationType operationType)

Convert a transaction operation to a representing IReplicationPacketData

createGenericOperationData

T createGenericOperationData(Object operationData,
                             ReplicationSingleOperationType operationType,
                             ReplicationOutContext entireContext)

createFix

IDataConsumeFix createFix(IDataConsumeResult errorResult,
                          T errorData)

Creates a fix for the given error result, that fixed should be applied at the corresponding IReplicationPacketDataConsumer

Parameters:

errorResult - the result that needs to be fixed

errorData - the data that created the error while being consumed

Returns:

the fix for the error result

toFilterEntries

Iterable<IReplicationFilterEntry> toFilterEntries(T data)

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

Returns:

collection of replication filter entries representing the data

convertSingleEntryData

T convertSingleEntryData(T singleEntryData,
                         ReplicationEntryDataConversionMetadata metadata,
                         PlatformLogicalVersion targetMemberVersion)
                  throws ReplicationPacketEntryDataConversionException

Convert the given data that has a single entry (IReplicationPacketData.isSingleEntryData() must be true) to the specified operation

Parameters:

singleEntryData - data to convert

metadata - conversion metadata

Returns:

new data converted to the new operation

Throws:

ReplicationPacketEntryDataConversionException - if the conversion is illegal

convertData

T convertData(T data,
              ReplicationMultipleOperationType convertToOperation,
              PlatformLogicalVersion targetMemberVersion)
       throws ReplicationPacketEntryDataConversionException

Converts the given data

Parameters:

data - data to convert

convertToOperation - which operation to convert to

Returns:

new data converted to the new operation

Throws:

ReplicationPacketEntryDataConversionException - if the conversion is illegal

convertEntryData

IReplicationPacketEntryData convertEntryData(IReplicationPacketEntryData entryData,
                                             ReplicationEntryDataConversionMetadata metadata,
                                             PlatformLogicalVersion targetMemberVersion)
                                      throws ReplicationPacketEntryDataConversionException

Converts the given entry data to the specified operation

Parameters:

entryData - entry data to convert

metadata - conversion metadata

Returns:

new entry data converted to the new operation

Throws:

ReplicationPacketEntryDataConversionException - if the conversion is illegal

createEmptyMultipleEntryData

T createEmptyMultipleEntryData(T data)

create an empty data of the same type of the given data, this data must not be IReplicationPacketData.isSingleEntryData()

Parameters:

data - template for data type creation

Returns:

empty data of the same type of the given data,

completePacketDataContent

void completePacketDataContent(T data)