Uses of Interface
com.gigaspaces.internal.cluster.node.impl.groups.IReplicationGroupHistory
Packages that use IReplicationGroupHistory
Package
Description
-
Uses of IReplicationGroupHistory in com.gigaspaces.internal.cluster.node.impl.backlog
Methods in com.gigaspaces.internal.cluster.node.impl.backlog with parameters of type IReplicationGroupHistoryModifier and TypeMethodDescriptionvoidAbstractSingleFileGroupBacklog.setGroupHistory(IReplicationGroupHistory groupHistory) voidIReplicationGroupBacklog.setGroupHistory(IReplicationGroupHistory groupHistory) -
Uses of IReplicationGroupHistory in com.gigaspaces.internal.cluster.node.impl.groups
Classes in com.gigaspaces.internal.cluster.node.impl.groups that implement IReplicationGroupHistoryModifier and TypeClassDescriptionclassAbstractReplicationSourceGroup<T extends SourceGroupConfig>classMethods in com.gigaspaces.internal.cluster.node.impl.groups with parameters of type IReplicationGroupHistoryModifier and TypeMethodDescriptionprotected abstract AbstractReplicationSourceChannelAbstractReplicationSourceGroup.createChannel(String memberLookupName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationChannelDataFilter dataFilter, IReplicationGroupHistory groupHistory, boolean dynamicMember, SourceGroupConfig groupConfig, Object customBacklogMetadata, boolean resetTarget) protected abstract AbstractReplicationTargetChannelAbstractReplicationTargetGroup.createNewChannelImpl(ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, IBacklogHandshakeRequest handshakeRequest, IReplicationGroupHistory groupHistory) Constructors in com.gigaspaces.internal.cluster.node.impl.groups with parameters of type IReplicationGroupHistoryModifierConstructorDescriptionAbstractReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig, String groupName, String memberName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationGroupBacklog groupBacklog, IReplicationOutFilter outFilter, IAsyncHandlerProvider asyncHandlerProvider, IReplicationChannelDataFilter dataFilter, IReplicationSourceGroupStateListener stateListener, IReplicationGroupHistory groupHistory, ReplicationStatistics.ReplicationMode channelType, Object customBacklogMetadata, String tag) AbstractReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig, String groupName, String memberName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationGroupBacklog groupBacklog, IReplicationOutFilter outFilter, IAsyncHandlerProvider asyncHandlerProvider, IReplicationChannelDataFilter dataFilter, IReplicationSourceGroupStateListener stateListener, IReplicationGroupHistory groupHistory, ReplicationStatistics.ReplicationMode channelType, Object customBacklogMetadata, String tag, boolean resetTarget) AbstractReplicationTargetChannel(TargetGroupConfig groupConfig, String myLookupName, Object myUniqueId, ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, String groupName, IReplicationTargetProcessLog processLog, IReplicationInFilter inFilter, IReplicationTargetGroupStateListener groupStateListener, IReplicationGroupHistory groupHistory, boolean wasEverActive) -
Uses of IReplicationGroupHistory in com.gigaspaces.internal.cluster.node.impl.groups.async
Classes in com.gigaspaces.internal.cluster.node.impl.groups.async that implement IReplicationGroupHistoryModifier and TypeClassDescriptionclassclassclassclassPrimary backup async target groupMethods in com.gigaspaces.internal.cluster.node.impl.groups.async with parameters of type IReplicationGroupHistoryModifier and TypeMethodDescriptionprotected AsyncReplicationTargetChannelAbstractAsyncReplicationTargetGroup.createChannel(ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, IBacklogHandshakeRequest handshakeRequest, IReplicationGroupHistory groupHistory) protected AbstractReplicationSourceChannelAsyncReplicationSourceGroup.createChannel(String memberLookupName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationChannelDataFilter dataFilter, IReplicationGroupHistory groupHistory, boolean dynamicMember, SourceGroupConfig groupConfig, Object customBacklogMetadata, boolean resetTarget) protected AbstractReplicationTargetChannelAsyncMultiOriginReplicationTargetGroup.createNewChannelImpl(ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, IBacklogHandshakeRequest handshakeRequest, IReplicationGroupHistory groupHistory) protected AbstractReplicationTargetChannelAsyncSingleOriginReplicationTargetGroup.createNewChannelImpl(ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, IBacklogHandshakeRequest handshakeRequest, IReplicationGroupHistory groupHistory) protected abstract IReplicationAsyncTargetProcessLogAbstractAsyncReplicationTargetGroup.createProcessLog(IReplicationAsyncProcessLogBuilder processLogBuilder, String sourceLookupName, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, IBacklogHandshakeRequest handshakeRequest, IReplicationGroupHistory groupHistory) protected IReplicationAsyncTargetProcessLogAsyncMultiOriginReplicationTargetGroup.createProcessLog(IReplicationAsyncProcessLogBuilder processLogBuilder, String sourceLookupName, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, IBacklogHandshakeRequest handshakeRequest, IReplicationGroupHistory groupHistory) protected IReplicationAsyncTargetProcessLogAsyncSingleOriginReplicationTargetGroup.createProcessLog(IReplicationAsyncProcessLogBuilder processLogBuilder, String sourceLookupName, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, IBacklogHandshakeRequest handshakeRequest, IReplicationGroupHistory groupHistory) Constructors in com.gigaspaces.internal.cluster.node.impl.groups.async with parameters of type IReplicationGroupHistoryModifierConstructorDescriptionAsyncReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig, String groupName, String memberName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationGroupBacklog groupBacklog, IReplicationOutFilter outFilter, int batchSize, long intervalMilis, int intervalOperations, IAsyncHandlerProvider asyncHandlerProvider, boolean autoStart, IReplicationChannelDataFilter dataFilter, IReplicationSourceGroupStateListener stateListener, IReplicationGroupHistory groupHistory, ReplicationStatistics.ReplicationMode channelType, Object customBacklogMetadata, String tag, boolean resetTarget) AsyncReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig, String groupName, String memberName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationGroupBacklog groupBacklog, IReplicationOutFilter outFilter, int batchSize, long intervalMilis, int intervalOperations, IAsyncHandlerProvider asyncHandlerProvider, IReplicationChannelDataFilter dataFilter, IReplicationSourceGroupStateListener stateListener, IReplicationGroupHistory groupHistory, ReplicationStatistics.ReplicationMode channelType, Object customBacklogMetadata, String tag) AsyncReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig, String groupName, String memberName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationGroupBacklog groupBacklog, IReplicationOutFilter outFilter, int batchSize, long intervalMilis, int intervalOperations, IAsyncHandlerProvider asyncHandlerProvider, IReplicationChannelDataFilter dataFilter, IReplicationSourceGroupStateListener stateListener, IReplicationGroupHistory groupHistory, ReplicationStatistics.ReplicationMode channelType, Object customBacklogMetadata, String tag, boolean resetTarget) AsyncReplicationTargetChannel(TargetGroupConfig groupConfig, String myLookupName, Object myUniqueId, ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, String groupName, IReplicationAsyncTargetProcessLog processLog, IReplicationInFilter inFilter, IReplicationTargetGroupStateListener groupStateListener, IReplicationGroupHistory groupHistory, boolean wasEverActive) -
Uses of IReplicationGroupHistory in com.gigaspaces.internal.cluster.node.impl.groups.reliableasync
Classes in com.gigaspaces.internal.cluster.node.impl.groups.reliableasync that implement IReplicationGroupHistoryModifier and TypeClassDescriptionclassclassclassMethods in com.gigaspaces.internal.cluster.node.impl.groups.reliableasync with parameters of type IReplicationGroupHistoryModifier and TypeMethodDescriptionprotected AbstractReplicationSourceChannelReliableAsyncReplicationSourceGroup.createChannel(String memberLookupName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationChannelDataFilter dataFilter, IReplicationGroupHistory groupHistory, boolean dynamicMember, SourceGroupConfig groupConfig, Object customBacklogMetadata, boolean resetTarget) protected AbstractReplicationTargetChannelReliableAsyncSingleOriginReplicationTargetGroup.createNewChannelImpl(ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, IBacklogHandshakeRequest handshakeRequest, IReplicationGroupHistory groupHistory) protected IReplicationSyncTargetProcessLogReliableAsyncKeeperReplicationTargetGroup.createProcessLog(TargetGroupConfig groupConfig, String sourceLookupName, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationGroupHistory groupHistory, IReplicationConnection sourceConnection) Constructors in com.gigaspaces.internal.cluster.node.impl.groups.reliableasync with parameters of type IReplicationGroupHistoryModifierConstructorDescriptionReliableAsyncReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig, String groupName, String memberName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationReliableAsyncGroupBacklog groupBacklog, IReplicationOutFilter outFilter, int batchSize, long intervalMilis, int intervalOperations, IAsyncHandlerProvider asyncHandlerProvider, Collection<SyncReplicationSourceChannel> keeperSyncChannelsCollection, IReplicationChannelDataFilter dataFilter, IReplicationSourceGroupStateListener stateListener, IReplicationGroupHistory groupHistory, ReplicationStatistics.ReplicationMode channelType, Object customBacklogMetadata, String tag, boolean resetTarget) -
Uses of IReplicationGroupHistory in com.gigaspaces.internal.cluster.node.impl.groups.sync
Classes in com.gigaspaces.internal.cluster.node.impl.groups.sync that implement IReplicationGroupHistoryModifier and TypeClassDescriptionclassclassclassIReplicationTargetGroupthat supports only multiple active source that is replicating to it (i.e active active sync replication)classclassIReplicationTargetGroupthat supports only one active source that is replicating to it (i.e primary backup topology, supports any number of backup)Methods in com.gigaspaces.internal.cluster.node.impl.groups.sync with parameters of type IReplicationGroupHistoryModifier and TypeMethodDescriptionprotected SyncReplicationTargetChannelAbstractSyncReplicationTargetGroup.createChannel(ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, IBacklogHandshakeRequest handshakeRequest, IReplicationGroupHistory groupHistory) protected AbstractReplicationSourceChannelSyncReplicationSourceGroup.createChannel(String memberLookupName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationChannelDataFilter dataFilter, IReplicationGroupHistory groupHistory, boolean dynamicMember, SourceGroupConfig groupConfig, Object customBacklogMetadata, boolean resetTarget) protected AbstractReplicationTargetChannelAbstractSyncSingleOriginReplicationTargetGroup.createNewChannelImpl(ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, IBacklogHandshakeRequest handshakeRequest, IReplicationGroupHistory groupHistory) protected AbstractReplicationTargetChannelSyncMultiOriginReplicationTargetGroup.createNewChannelImpl(ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, IBacklogHandshakeRequest handshakeRequest, IReplicationGroupHistory groupHistory) protected abstract IReplicationSyncTargetProcessLogAbstractSyncReplicationTargetGroup.createProcessLog(TargetGroupConfig groupConfig, String sourceLookupName, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationGroupHistory groupHistory, IReplicationConnection sourceConnection) protected IReplicationSyncTargetProcessLogSyncMultiOriginReplicationTargetGroup.createProcessLog(TargetGroupConfig groupConfig, String sourceLookupName, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationGroupHistory groupHistory, IReplicationConnection sourceConnection) protected IReplicationSyncTargetProcessLogSyncSingleOriginReplicationTargetGroup.createProcessLog(TargetGroupConfig groupConfig, String sourceLookupName, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationGroupHistory groupHistory, IReplicationConnection sourceConnection) Constructors in com.gigaspaces.internal.cluster.node.impl.groups.sync with parameters of type IReplicationGroupHistoryModifierConstructorDescriptionSyncReplicationSourceChannel(DynamicSourceGroupConfigHolder groupConfig, String groupName, String memberName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationGroupBacklog groupBacklog, IReplicationOutFilter outFilter, IReplicationThrottleController throttleController, IAsyncHandlerProvider asyncHandlerProvider, int asyncStateBatchSize, long idleDelayMilis, IReplicationChannelDataFilter dataFilter, IReplicationSourceGroupStateListener stateListener, IReplicationGroupHistory groupHistory, ReplicationStatistics.ReplicationMode channelType, Object customBacklogMetadata) SyncReplicationTargetChannel(TargetGroupConfig groupConfig, String myLookupName, Object myUniqueId, ReplicationEndpointDetails sourceEndpointDetails, IReplicationMonitoredConnection sourceConnection, String groupName, IReplicationSyncTargetProcessLog processLog, IReplicationInFilter inFilter, IReplicationTargetGroupStateListener groupStateListener, IReplicationGroupHistory groupHistory) -
Uses of IReplicationGroupHistory in com.gigaspaces.internal.cluster.node.impl.processlog
Methods in com.gigaspaces.internal.cluster.node.impl.processlog that return IReplicationGroupHistoryMethods in com.gigaspaces.internal.cluster.node.impl.processlog with parameters of type IReplicationGroupHistoryModifier and TypeMethodDescriptionReliableAsyncAdaptiveProcessLogBuilder.createAsyncProcessLog(TargetGroupConfig groupConfig, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory) ReliableAsyncAdaptiveProcessLogBuilder.createBatchConsumeAsyncProcessLog(TargetGroupConfig groupConfig, IBacklogHandshakeRequest handshakeRequest, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory) ReliableAsyncAdaptiveProcessLogBuilder.createReliableAsyncKeeperProcessLog(TargetGroupConfig groupConfig, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory, IReplicationReliableAsyncMediator mediator, IReplicationSyncTargetProcessLog synchronizingProcessLog) ReliableAsyncAdaptiveProcessLogBuilder.createReliableAsyncProcessLog(TargetGroupConfig groupConfig, IBacklogHandshakeRequest handshakeRequest, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationReliableAsyncTargetProcessLog synchronizingProcessLog, IReplicationGroupHistory groupHistory, org.slf4j.Logger specificLogger) ReliableAsyncAdaptiveProcessLogBuilder.createSyncProcessLog(TargetGroupConfig groupConfig, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory) Constructors in com.gigaspaces.internal.cluster.node.impl.processlog with parameters of type IReplicationGroupHistoryModifierConstructorDescriptionAbstractSingleFileTargetProcessLog(IReplicationPacketDataConsumer dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory) -
Uses of IReplicationGroupHistory in com.gigaspaces.internal.cluster.node.impl.processlog.async
Methods in com.gigaspaces.internal.cluster.node.impl.processlog.async with parameters of type IReplicationGroupHistoryModifier and TypeMethodDescriptionIReplicationAsyncProcessLogBuilder.createAsyncProcessLog(TargetGroupConfig groupConfig, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory) IReplicationAsyncProcessLogBuilder.createBatchConsumeAsyncProcessLog(TargetGroupConfig groupConfig, IBacklogHandshakeRequest handshakeRequest, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupNameString, String sourceLookupName, IReplicationGroupHistory groupHistory) -
Uses of IReplicationGroupHistory in com.gigaspaces.internal.cluster.node.impl.processlog.globalorder
Methods in com.gigaspaces.internal.cluster.node.impl.processlog.globalorder with parameters of type IReplicationGroupHistoryModifier and TypeMethodDescriptionGlobalOrderProcessLogBuilder.createAsyncProcessLog(TargetGroupConfig groupConfig, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory) GlobalOrderProcessLogBuilder.createBatchConsumeAsyncProcessLog(TargetGroupConfig groupConfig, IBacklogHandshakeRequest handshakeRequest, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory) GlobalOrderProcessLogBuilder.createReliableAsyncKeeperProcessLog(TargetGroupConfig groupConfig, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory, IReplicationReliableAsyncMediator mediator, IReplicationSyncTargetProcessLog synchronizingProcessLog) GlobalOrderProcessLogBuilder.createReliableAsyncProcessLog(TargetGroupConfig groupConfig, IBacklogHandshakeRequest handshakeRequest, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationReliableAsyncTargetProcessLog synchronizingProcessLog, IReplicationGroupHistory groupHistory, org.slf4j.Logger specificLogger) GlobalOrderProcessLogBuilder.createSyncProcessLog(TargetGroupConfig groupConfig, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory) Constructors in com.gigaspaces.internal.cluster.node.impl.processlog.globalorder with parameters of type IReplicationGroupHistoryModifierConstructorDescriptionAbstractGlobalOrderTargetProcessLog(IReplicationPacketDataConsumer dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long lastProcessedKey, boolean firstHandshakeForTarget, IReplicationGroupHistory groupHistory) protectedGlobalOrderBatchConsumeTargetProcessLog(IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long lastProcessedKey, boolean firstHandshakeForTarget, IReplicationGroupHistory groupHistory) GlobalOrderBatchConsumeTargetProcessLog(IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory) GlobalOrderReliableAsyncTargetKeeperProcessLog(GlobalOrderProcessLogConfig processLogConfig, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, boolean oneWayMode, IReplicationGroupHistory groupHistory, IReplicationReliableAsyncMediator mediator) GlobalOrderReliableAsyncTargetKeeperProcessLog(GlobalOrderProcessLogConfig processLogConfig, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long lastProcessedKey, boolean isFirstHandshake, boolean oneWayMode, IReplicationGroupHistory groupHistory, IReplicationReliableAsyncMediator mediator) GlobalOrderReliableAsyncTargetProcessLog(IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long lastProcessedKey, boolean firstHandshakeForTarget, IReplicationGroupHistory groupHistory) GlobalOrderReliableAsyncTargetProcessLog(IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory) GlobalOrderTargetProcessLog(GlobalOrderProcessLogConfig processLogConfig, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, boolean oneWayProcessing, IReplicationGroupHistory groupHistory) GlobalOrderTargetProcessLog(GlobalOrderProcessLogConfig processLogConfig, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long lastProcessedKey, boolean isFirstHandshake, boolean oneWayProcessing, IReplicationGroupHistory groupHistory) -
Uses of IReplicationGroupHistory in com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile
Methods in com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile with parameters of type IReplicationGroupHistoryModifier and TypeMethodDescriptionMultiBucketSingleFileProcessLogBuilder.createAsyncProcessLog(TargetGroupConfig groupConfig, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory) MultiBucketSingleFileProcessLogBuilder.createBatchConsumeAsyncProcessLog(TargetGroupConfig groupConfig, IBacklogHandshakeRequest handshakeRequest, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory) MultiBucketSingleFileProcessLogBuilder.createReliableAsyncKeeperProcessLog(TargetGroupConfig groupConfig, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory, IReplicationReliableAsyncMediator mediator, IReplicationSyncTargetProcessLog synchronizingProcessLog) MultiBucketSingleFileProcessLogBuilder.createReliableAsyncProcessLog(TargetGroupConfig groupConfig, IBacklogHandshakeRequest handshakeRequest, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationReliableAsyncTargetProcessLog synchronizingProcessLog, IReplicationGroupHistory groupHistory, org.slf4j.Logger specificLogger) MultiBucketSingleFileProcessLogBuilder.createSyncProcessLog(TargetGroupConfig groupConfig, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory) Constructors in com.gigaspaces.internal.cluster.node.impl.processlog.multibucketsinglefile with parameters of type IReplicationGroupHistoryModifierConstructorDescriptionprotectedAbstractMultiBucketSingleFileTargetProcessLog(ProcessLogConfig config, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long[] lastProcessedKeys, long[] lastGlobalProcessedKeys, boolean firstHandshakeForTarget, IReplicationGroupHistory groupHistory) AbstractMultiBucketSingleFileTargetProcessLog(ProcessLogConfig config, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory) protectedMultiBucketSingleFileBatchConsumeTargetProcessLog(ProcessLogConfig config, IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long lastGlobalProcessedKey, long[] lastProcessedKeys, long[] lastGlobalProcessedKeys, boolean firstHandshakeForTarget, IReplicationGroupHistory groupHistory) MultiBucketSingleFileBatchConsumeTargetProcessLog(ProcessLogConfig config, IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory) MultiBucketSingleFileReliableAsyncTargetKeeperProcessLog(ProcessLogConfig config, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory, IReplicationReliableAsyncMediator mediator) MultiBucketSingleFileReliableAsyncTargetKeeperProcessLog(ProcessLogConfig config, IReplicationPacketDataConsumer dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long[] lastProcessedKeys, long[] lastGlobalProcessedKeys, boolean firstHandshakeForTarget, IReplicationGroupHistory groupHistory, IReplicationReliableAsyncMediator mediator) MultiBucketSingleFileReliableAsyncTargetProcessLog(ProcessLogConfig config, IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long lastGlobalProcessedKey, long[] lastProcessedKeys, long[] lastGlobalProcessedKeys, boolean firstHandshakeForTarget, IReplicationGroupHistory groupHistory) MultiBucketSingleFileReliableAsyncTargetProcessLog(ProcessLogConfig config, IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory) MultiBucketSingleFileSyncTargetProcessLog(ProcessLogConfig config, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory) MultiBucketSingleFileSyncTargetProcessLog(ProcessLogConfig config, IReplicationPacketDataConsumer dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long[] lastProcessedKeys, long[] lastGlobalProcessedKeys, boolean firstHandshakeForTarget, IReplicationGroupHistory groupHistory) -
Uses of IReplicationGroupHistory in com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile
Methods in com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile with parameters of type IReplicationGroupHistoryModifier and TypeMethodDescriptionMultiSourceSingleFileProcessLogBuilder.createAsyncProcessLog(TargetGroupConfig groupConfig, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory) MultiSourceSingleFileProcessLogBuilder.createBatchConsumeAsyncProcessLog(TargetGroupConfig groupConfig, IBacklogHandshakeRequest handshakeRequest, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory) MultiSourceSingleFileProcessLogBuilder.createReliableAsyncKeeperProcessLog(TargetGroupConfig groupConfig, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory, IReplicationReliableAsyncMediator mediator, IReplicationSyncTargetProcessLog synchronizingProcessLog) MultiSourceSingleFileProcessLogBuilder.createReliableAsyncProcessLog(TargetGroupConfig groupConfig, IBacklogHandshakeRequest handshakeRequest, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationReliableAsyncTargetProcessLog synchronizingProcessLog, IReplicationGroupHistory groupHistory, org.slf4j.Logger specificLogger) MultiSourceSingleFileProcessLogBuilder.createSyncOneWayProcessLog(TargetGroupConfig groupConfig, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory) MultiSourceSingleFileProcessLogBuilder.createSyncProcessLog(TargetGroupConfig groupConfig, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory) Constructors in com.gigaspaces.internal.cluster.node.impl.processlog.multisourcesinglefile with parameters of type IReplicationGroupHistoryModifierConstructorDescriptionMultiSourceSingleFileReliableAsyncTargetKeeperProcessLog(MultiSourceSingleFileProcessLogConfig processLogConfig, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, boolean oneWayMode, IReplicationGroupHistory groupHistory, IReplicationReliableAsyncMediator mediator) MultiSourceSingleFileReliableAsyncTargetKeeperProcessLog(MultiSourceSingleFileProcessLogConfig processLogConfig, IReplicationPacketDataConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, long lastProcessedKey, boolean isFirstHandshake, boolean oneWayMode, IReplicationGroupHistory groupHistory, IReplicationReliableAsyncMediator mediator) MultiSourceSingleFileReliableAsyncTargetProcessLog(MultiSourceSingleFileProcessLogConfig processLogConfig, IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String myLookupName, String groupName, String sourceLookupName, boolean firstHandshakeForTarget, IReplicationGroupHistory groupHistory, IReplicationParticipantsMediator participantsMediator, long lastProcessedKey, long firstUnprocessedKey, LinkedList<MultiSourceProcessLogPacket> pendingPacketsQueue, HashMap<String, MultiSourceProcessLogPacket> packetsByUidHelperMap, IProcessMemoryManager processMemoryManager) MultiSourceSingleFileReliableAsyncTargetProcessLog(MultiSourceSingleFileProcessLogConfig processLogConfig, IReplicationPacketDataBatchConsumer<?> dataConsumer, IReplicationProcessLogExceptionHandler exceptionHandler, IReplicationInFacade replicationInFacade, String name, String groupName, String sourceLookupName, boolean firstHandshakeForTarget, IReplicationGroupHistory groupHistory, IReplicationParticipantsMediator participantsMediator, IProcessMemoryManager processMemoryManager) -
Uses of IReplicationGroupHistory in com.gigaspaces.internal.cluster.node.impl.processlog.reliableasync
Methods in com.gigaspaces.internal.cluster.node.impl.processlog.reliableasync with parameters of type IReplicationGroupHistoryModifier and TypeMethodDescriptionIReplicationReliableAsyncKeeperProcessLogBuilder.createReliableAsyncKeeperProcessLog(TargetGroupConfig groupConfig, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory, IReplicationReliableAsyncMediator mediator, IReplicationSyncTargetProcessLog synchronizingProcessLog) IReplicationReliableAsyncProcessLogBuilder.createReliableAsyncProcessLog(TargetGroupConfig groupConfig, IBacklogHandshakeRequest handshakeRequest, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationReliableAsyncTargetProcessLog synchronizingProcessLog, IReplicationGroupHistory groupHistory, org.slf4j.Logger specificLogger) -
Uses of IReplicationGroupHistory in com.gigaspaces.internal.cluster.node.impl.processlog.sync
Methods in com.gigaspaces.internal.cluster.node.impl.processlog.sync with parameters of type IReplicationGroupHistoryModifier and TypeMethodDescriptionIReplicationSyncProcessLogBuilder.createSyncProcessLog(TargetGroupConfig groupConfig, IReplicationInFacade replicationInFacade, IReplicationProcessLogExceptionHandler exceptionHandler, String myLookupName, String groupName, String sourceLookupName, IReplicationGroupHistory groupHistory)