Package com.gigaspaces.internal.cluster.node.impl.config

Class ReplicationNodeConfigBuilder

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.config.ReplicationNodeConfigBuilder

Direct Known Subclasses:

ReplicationNodeWithGatewayConfigBuilder

public class ReplicationNodeConfigBuilder
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected static final org.slf4j.Logger	_logger
static final String	ASYNC
static final String	ASYNC_MIRROR
static final String	PERSISTENCY_GROUPING_NAME
static final String	PRIMARY_BACKUP_ASYNC
static final String	PRIMARY_BACKUP_RELIABLE_ASYNC
static final String	PRIMARY_BACKUP_RELIABLE_ASYNC_NO_MIRROR
static final String	PRIMARY_BACKUP_SYNC
static final String	SYNC
static final long	UNLIMITED

Constructor Summary

Constructors

Constructor	Description
ReplicationNodeConfigBuilder()

Method Summary

Modifier and Type	Method	Description
void	addKeepersFilters(IReliableAsyncReplicationSettings reliableAsyncSettings, String groupName, List<String> groupMemberNames, Map<String,IReplicationChannelDataFilter> filters, boolean requiresEvictionReplicationProtection)
void	addKeepersListeners(Map<String,IReplicationChannelDataFilter> filters, DynamicReliableAsyncSourceGroupConfigHolder configHolder)
void	configureBacklogLimitations(ISpaceReplicationSettings replicationPolicy, BacklogConfig backlogConfig, List<String> groupMemberNames)
void	configureMirrorBacklogLimitations(IReplicationSettings mirrorSettings, BacklogConfig backlogConfig, List<String> mirrorMembersNames)
ReplicationNodeConfig	createAsyncReplicationConfig(ISpaceReplicationSettings replicationPolicy, IReplicationNodeBuilder nodeBuilder)
BacklogConfig	createBacklogConfig(ISpaceReplicationSettings replicationPolicy, IMirrorChannelReplicationSettings mirrorPolicy, boolean supportsConcurrentReplication, boolean supportsMultiSourceReplication)
BacklogConfig	createBacklogConfig(ISpaceReplicationSettings replicationPolicy, IMirrorChannelReplicationSettings mirrorPolicy, IReplicationComponentPolicy replicationComponentPolicy, boolean supportsConcurrentReplication, boolean supportsMultiSourceReplication)
ReplicationNodeConfig	createConfig(SpaceClusterInfo clusterInfo, ClusterPolicy clusterPolicy, IReplicationNodeBuilder nodeBuilder, ReplicationFilterManager filterManager, int partitionId, IStorageAdapter storageAdapter, SpaceConfigReader configReader, IReplicationChannelDataFilterBuilder filterBuilder, IDynamicSourceGroupMemberLifeCycleBuilder lifeCycleBuilder)
List<String>	createGroupMemberNames(ISpaceReplicationSettings settings)
ReplicationNodeConfig	createLocalViewConfig(String spaceName, SpaceClusterInfo clusterInfo, ReplicationNodeBuilder nodeBuilder, int partitions)
Map<String,String[]>	createMembersGroupingForMirror(String mirrorMemberName)
ReplicationNodeConfig	createMirrorConfig(MirrorConfig mirrorConfig, ReplicationNodeBuilder nodeBuilder)
ReplicationNodeConfig	createMirrorConfig(String spaceName, ReplicationNodeBuilder nodeBuilder, int partitions, int backups)
ReplicationNodeConfig	createNotificationConfig(String spaceName, SpaceClusterInfo clusterInfo, ReplicationNodeBuilder nodeBuilder, int partitionIndex, int numOfPartitions)
ReplicationNodeConfig	createPrimaryBackupAsyncConfig(ISpaceReplicationSettings replicationPolicy, IReplicationNodeBuilder nodeBuilder)
ReplicationNodeConfig	createPrimaryBackupSyncConfig(ISpaceReplicationSettings replicationPolicy, IReplicationNodeBuilder nodeBuilder, int partitionId)
ReplicationNodeConfig	createPrimaryNoBackupReplicationConfig(ISpaceReplicationSettings replicationPolicy, IReplicationNodeBuilder nodeBuilder, int partitionId)
ProcessLogConfig	createProcessLogConfig(ISpaceReplicationSettings replicationPolicy, boolean supportsConcurrentReplication, boolean supportsMultiSource)
ReplicationNodeConfig	createReliableAsyncSourceConfig(IReliableAsyncReplicationSettings reliableAsyncSettings, IReplicationNodeBuilder nodeBuilder, int partitionId, IReplicationChannelDataFilterBuilder filterBuilder, IDynamicSourceGroupMemberLifeCycleBuilder lifeCycleBuilder)
ReplicationNodeConfig	createReliableAsyncSourceWithMirrorConfig(IReliableAsyncReplicationSettings reliableAsyncSettings, IReplicationNodeBuilder nodeBuilder, int partitionId, IReplicationChannelDataFilterBuilder filterBuilder, IDynamicSourceGroupMemberLifeCycleBuilder lifeCycleBuilder, boolean requiresEvictionReplicationProtection)
String	createReplicationGroupName(int partitionId, boolean primaryBackupGroup, boolean syncReplication, boolean hasMirror, boolean hasExistingReplicationMembers)
String	createReplicationGroupName(int partitionId, String spaceMemberName, SpaceClusterInfo clusterInfo, boolean primaryBackupGroup)
ReplicationNodeConfig	createSourceWithMirrorConfig(MirrorReplicationSettingsAdapter mirrorPolicy, ISpaceReplicationSettings replicationPolicy, IReplicationNodeBuilder nodeBuilder, int partitionId, boolean requiresEvictionReplicationProtection)
IReplicationThrottleControllerBuilder	createSyncGroupThrottleController(IReplicationSettings replicationPolicy)
ReplicationNodeConfig	createSyncReplicationConfig(ISpaceReplicationSettings replicationPolicy, IReplicationNodeBuilder nodeBuilder)
protected boolean	dataSourceSupportsVersioning(SpaceConfigReader configReader)
GroupConsistencyLevelPolicy	getGroupConsistencyLevel(ISpaceReplicationSettings replicationPolicy, List<String> syncGroupMemberNames)
static ReplicationNodeConfigBuilder	getInstance()
String	getSynchronizeGroupName(SpaceClusterInfo clusterInfo, int partitionId, String spaceMemberName)
protected boolean	isCentralDB(IStorageAdapter storageAdapter, ClusterPolicy clusterPolicy)
protected boolean	isEvictableCachePolicy(SpaceConfigReader configReader)
protected boolean	reliableAsyncKeeperCannotRefillContent(ClusterPolicy clusterPolicy, IStorageAdapter storageAdapter, SpaceConfigReader configReader)
protected boolean	requiresEvictionReplicationProtection(ClusterPolicy clusterPolicy, IStorageAdapter storageAdapter, SpaceConfigReader configReader)
void	setReplicationFilters(IReplicationSettings replicationPolicy, ReplicationNodeConfig replicationNodeConfig)
String	supportsMultiSourceReplication(SpaceClusterInfo clusterInfo)
void	validateConfig(ISpaceReplicationSettings replicationPolicy)
protected void	validateSupportedConfig(ClusterPolicy clusterPolicy)

Methods inherited from class java.lang.Object

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

Field Details

PRIMARY_BACKUP_RELIABLE_ASYNC

public static final String PRIMARY_BACKUP_RELIABLE_ASYNC

See Also:

• Constant Field Values

PRIMARY_BACKUP_RELIABLE_ASYNC_NO_MIRROR

public static final String PRIMARY_BACKUP_RELIABLE_ASYNC_NO_MIRROR

See Also:

• Constant Field Values

ASYNC_MIRROR

public static final String ASYNC_MIRROR

See Also:

• Constant Field Values

ASYNC

public static final String ASYNC

See Also:

• Constant Field Values

SYNC

public static final String SYNC

See Also:

• Constant Field Values

PRIMARY_BACKUP_SYNC

public static final String PRIMARY_BACKUP_SYNC

See Also:

• Constant Field Values

PRIMARY_BACKUP_ASYNC

public static final String PRIMARY_BACKUP_ASYNC

See Also:

• Constant Field Values

UNLIMITED

public static final long UNLIMITED

See Also:

• Constant Field Values

PERSISTENCY_GROUPING_NAME

public static final String PERSISTENCY_GROUPING_NAME

See Also:

• Constant Field Values

_logger

protected static final org.slf4j.Logger _logger

Constructor Details

ReplicationNodeConfigBuilder

public ReplicationNodeConfigBuilder()

Method Details

getInstance

public static ReplicationNodeConfigBuilder getInstance()

requiresEvictionReplicationProtection

protected boolean requiresEvictionReplicationProtection(ClusterPolicy clusterPolicy,
 IStorageAdapter storageAdapter,
 SpaceConfigReader configReader)

reliableAsyncKeeperCannotRefillContent

protected boolean reliableAsyncKeeperCannotRefillContent(ClusterPolicy clusterPolicy,
 IStorageAdapter storageAdapter,
 SpaceConfigReader configReader)

createConfig

public ReplicationNodeConfig createConfig(SpaceClusterInfo clusterInfo,
 ClusterPolicy clusterPolicy,
 IReplicationNodeBuilder nodeBuilder,
 ReplicationFilterManager filterManager,
 int partitionId,
 IStorageAdapter storageAdapter,
 SpaceConfigReader configReader,
 IReplicationChannelDataFilterBuilder filterBuilder,
 IDynamicSourceGroupMemberLifeCycleBuilder lifeCycleBuilder)

dataSourceSupportsVersioning

protected boolean dataSourceSupportsVersioning(SpaceConfigReader configReader)

isEvictableCachePolicy

protected boolean isEvictableCachePolicy(SpaceConfigReader configReader)

isCentralDB

protected boolean isCentralDB(IStorageAdapter storageAdapter,
 ClusterPolicy clusterPolicy)

validateSupportedConfig

protected void validateSupportedConfig(ClusterPolicy clusterPolicy)

createAsyncReplicationConfig

public ReplicationNodeConfig createAsyncReplicationConfig(ISpaceReplicationSettings replicationPolicy,
 IReplicationNodeBuilder nodeBuilder)

createPrimaryNoBackupReplicationConfig

public ReplicationNodeConfig createPrimaryNoBackupReplicationConfig(ISpaceReplicationSettings replicationPolicy,
 IReplicationNodeBuilder nodeBuilder,
 int partitionId)

createSyncReplicationConfig

public ReplicationNodeConfig createSyncReplicationConfig(ISpaceReplicationSettings replicationPolicy,
 IReplicationNodeBuilder nodeBuilder)

createPrimaryBackupSyncConfig

public ReplicationNodeConfig createPrimaryBackupSyncConfig(ISpaceReplicationSettings replicationPolicy,
 IReplicationNodeBuilder nodeBuilder,
 int partitionId)

createPrimaryBackupAsyncConfig

public ReplicationNodeConfig createPrimaryBackupAsyncConfig(ISpaceReplicationSettings replicationPolicy,
 IReplicationNodeBuilder nodeBuilder)

createBacklogConfig

public BacklogConfig createBacklogConfig(ISpaceReplicationSettings replicationPolicy,
 IMirrorChannelReplicationSettings mirrorPolicy,
 boolean supportsConcurrentReplication,
 boolean supportsMultiSourceReplication)

createBacklogConfig

public BacklogConfig createBacklogConfig(ISpaceReplicationSettings replicationPolicy,
 IMirrorChannelReplicationSettings mirrorPolicy,
 IReplicationComponentPolicy replicationComponentPolicy,
 boolean supportsConcurrentReplication,
 boolean supportsMultiSourceReplication)

createSyncGroupThrottleController

public IReplicationThrottleControllerBuilder createSyncGroupThrottleController(IReplicationSettings replicationPolicy)

createGroupMemberNames

public List<String> createGroupMemberNames(ISpaceReplicationSettings settings)

createReliableAsyncSourceConfig

public ReplicationNodeConfig createReliableAsyncSourceConfig(IReliableAsyncReplicationSettings reliableAsyncSettings,
 IReplicationNodeBuilder nodeBuilder,
 int partitionId,
 IReplicationChannelDataFilterBuilder filterBuilder,
 IDynamicSourceGroupMemberLifeCycleBuilder lifeCycleBuilder)

getGroupConsistencyLevel

public GroupConsistencyLevelPolicy getGroupConsistencyLevel(ISpaceReplicationSettings replicationPolicy,
 List<String> syncGroupMemberNames)

addKeepersListeners

public void addKeepersListeners(Map<String,IReplicationChannelDataFilter> filters,
 DynamicReliableAsyncSourceGroupConfigHolder configHolder)

addKeepersFilters

public void addKeepersFilters(IReliableAsyncReplicationSettings reliableAsyncSettings,
 String groupName,
 List<String> groupMemberNames,
 Map<String,IReplicationChannelDataFilter> filters,
 boolean requiresEvictionReplicationProtection)

createReliableAsyncSourceWithMirrorConfig

public ReplicationNodeConfig createReliableAsyncSourceWithMirrorConfig(IReliableAsyncReplicationSettings reliableAsyncSettings,
 IReplicationNodeBuilder nodeBuilder,
 int partitionId,
 IReplicationChannelDataFilterBuilder filterBuilder,
 IDynamicSourceGroupMemberLifeCycleBuilder lifeCycleBuilder,
 boolean requiresEvictionReplicationProtection)

createMembersGroupingForMirror

public Map<String,String[]> createMembersGroupingForMirror(String mirrorMemberName)

validateConfig

public void validateConfig(ISpaceReplicationSettings replicationPolicy)

createSourceWithMirrorConfig

public ReplicationNodeConfig createSourceWithMirrorConfig(MirrorReplicationSettingsAdapter mirrorPolicy,
 ISpaceReplicationSettings replicationPolicy,
 IReplicationNodeBuilder nodeBuilder,
 int partitionId,
 boolean requiresEvictionReplicationProtection)

createMirrorConfig

public ReplicationNodeConfig createMirrorConfig(MirrorConfig mirrorConfig,
 ReplicationNodeBuilder nodeBuilder)

createMirrorConfig

public ReplicationNodeConfig createMirrorConfig(String spaceName,
 ReplicationNodeBuilder nodeBuilder,
 int partitions,
 int backups)

createLocalViewConfig

public ReplicationNodeConfig createLocalViewConfig(String spaceName,
 SpaceClusterInfo clusterInfo,
 ReplicationNodeBuilder nodeBuilder,
 int partitions)

createNotificationConfig

public ReplicationNodeConfig createNotificationConfig(String spaceName,
 SpaceClusterInfo clusterInfo,
 ReplicationNodeBuilder nodeBuilder,
 int partitionIndex,
 int numOfPartitions)

getSynchronizeGroupName

public String getSynchronizeGroupName(SpaceClusterInfo clusterInfo,
 int partitionId,
 String spaceMemberName)

createReplicationGroupName

public String createReplicationGroupName(int partitionId,
 boolean primaryBackupGroup,
 boolean syncReplication,
 boolean hasMirror,
 boolean hasExistingReplicationMembers)

createReplicationGroupName

public String createReplicationGroupName(int partitionId,
 String spaceMemberName,
 SpaceClusterInfo clusterInfo,
 boolean primaryBackupGroup)

configureBacklogLimitations

public void configureBacklogLimitations(ISpaceReplicationSettings replicationPolicy,
 BacklogConfig backlogConfig,
 List<String> groupMemberNames)

configureMirrorBacklogLimitations

public void configureMirrorBacklogLimitations(IReplicationSettings mirrorSettings,
 BacklogConfig backlogConfig,
 List<String> mirrorMembersNames)

createProcessLogConfig

public ProcessLogConfig createProcessLogConfig(ISpaceReplicationSettings replicationPolicy,
 boolean supportsConcurrentReplication,
 boolean supportsMultiSource)

setReplicationFilters

public void setReplicationFilters(IReplicationSettings replicationPolicy,
 ReplicationNodeConfig replicationNodeConfig)

supportsMultiSourceReplication

public String supportsMultiSourceReplication(SpaceClusterInfo clusterInfo)