Package com.gigaspaces.internal.cluster.node.impl.backlog.globalorder

Class GlobalOrderBacklogBuilder

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.backlog.globalorder.GlobalOrderBacklogBuilder

All Implemented Interfaces:

IReplicationAsyncBacklogBuilder, IReplicationBacklogBuilder, IReplicationReliableAsyncBacklogBuilder, IReplicationSyncBacklogBuilder

public class GlobalOrderBacklogBuilder
extends Object
implements IReplicationBacklogBuilder

Builds IReplicationGroupBacklog that each group has a global order that the packets must be processed by the corresponding IReplicationTargetProcessLog. The order is generated by the order of which the packets were inserted to the backlog In other words, the backlog is a single list of packets such that a packet can be processed by the target only if all the packets that appear before it in the list were processed.

Since:

8.0

Author:

eitany

Constructor Summary

Constructors

Constructor	Description
GlobalOrderBacklogBuilder(IReplicationPacketDataProducer<?> dataProducer, String name)

Method Summary

Modifier and Type	Method	Description
GlobalOrderAsyncGroupBacklog	createAsyncGroupBacklog(DynamicSourceGroupConfigHolder groupConfig)
GlobalOrderReliableAsyncGroupBacklog	createReliableAsyncGroupBacklog(DynamicSourceGroupConfigHolder groupConfig)	Create a backlog for a reliable async IReplicationSourceGroup
GlobalOrderSyncGroupBacklog	createSyncGroupBacklog(DynamicSourceGroupConfigHolder groupConfig)	Create a backlog for a sync IReplicationSourceGroup
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

GlobalOrderBacklogBuilder

public GlobalOrderBacklogBuilder(IReplicationPacketDataProducer<?> dataProducer,
 String name)

Method Details

createSyncGroupBacklog

public GlobalOrderSyncGroupBacklog createSyncGroupBacklog(DynamicSourceGroupConfigHolder groupConfig)

Description copied from interface: IReplicationSyncBacklogBuilder

Create a backlog for a sync IReplicationSourceGroup

Specified by:

createSyncGroupBacklog in interface IReplicationSyncBacklogBuilder

Parameters:

groupConfig - the group config

Returns:

created backlog

createAsyncGroupBacklog

public GlobalOrderAsyncGroupBacklog createAsyncGroupBacklog(DynamicSourceGroupConfigHolder groupConfig)

Specified by:

createAsyncGroupBacklog in interface IReplicationAsyncBacklogBuilder

createReliableAsyncGroupBacklog

public GlobalOrderReliableAsyncGroupBacklog createReliableAsyncGroupBacklog(DynamicSourceGroupConfigHolder groupConfig)

Description copied from interface: IReplicationReliableAsyncBacklogBuilder

Create a backlog for a reliable async IReplicationSourceGroup

Specified by:

createReliableAsyncGroupBacklog in interface IReplicationReliableAsyncBacklogBuilder

Parameters:

groupConfig - the group config

Returns:

created backlog

toString

public String toString()

Overrides:

toString in class Object