Uses of Interface
com.gigaspaces.internal.cluster.node.impl.groups.IReplicationChannelDataFilter

Packages that use IReplicationChannelDataFilter

Package	Description
com.gigaspaces.internal.cluster.node.impl.backlog
com.gigaspaces.internal.cluster.node.impl.backlog.globalorder
com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile
com.gigaspaces.internal.cluster.node.impl.backlog.multisourcesinglefile
com.gigaspaces.internal.cluster.node.impl.backlog.reliableasync
com.gigaspaces.internal.cluster.node.impl.config
com.gigaspaces.internal.cluster.node.impl.groups
com.gigaspaces.internal.cluster.node.impl.groups.async
com.gigaspaces.internal.cluster.node.impl.groups.reliableasync
com.gigaspaces.internal.cluster.node.impl.groups.sync
com.gigaspaces.internal.cluster.node.impl.notification
com.gigaspaces.internal.cluster.node.impl.view
com.gigaspaces.internal.server.space.replication

Uses of IReplicationChannelDataFilter in com.gigaspaces.internal.cluster.node.impl.backlog

Methods in com.gigaspaces.internal.cluster.node.impl.backlog with parameters of type IReplicationChannelDataFilter

Modifier and Type	Method and Description
List<IReplicationOrderedPacket>	IReplicationGroupBacklog.getPackets(String memberName, int maxSize, IReplicationChannelDataFilter filter, PlatformLogicalVersion targetMemberVersion, Logger logger)
List<IReplicationOrderedPacket>	AbstractSingleFileGroupBacklog.getPackets(String memberName, int maxSize, IReplicationChannelDataFilter filter, PlatformLogicalVersion targetMemberVersion, Logger logger)
List<IReplicationOrderedPacket>	AbstractSingleFileGroupBacklog.getPacketsUnsafe(String memberName, int maxSize, long upToKey, IReplicationChannelDataFilter dataFilter, IPacketFilteredHandler filteredHandler, PlatformLogicalVersion targetMemberVersion, Logger logger)

Uses of IReplicationChannelDataFilter in com.gigaspaces.internal.cluster.node.impl.backlog.globalorder

Methods in com.gigaspaces.internal.cluster.node.impl.backlog.globalorder with parameters of type IReplicationChannelDataFilter

Modifier and Type	Method and Description
List<IReplicationOrderedPacket>	GlobalOrderReliableAsyncGroupBacklog.getReliableAsyncPackets(String memberName, int maxSize, IReplicationReliableAsyncGroupBacklog.KeeperMemberState[] keeperMembersState, IReplicationChannelDataFilter dataFilter, PlatformLogicalVersion targetMemberVersion, Logger logger)

Uses of IReplicationChannelDataFilter in com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile

Methods in com.gigaspaces.internal.cluster.node.impl.backlog.multibucketsinglefile with parameters of type IReplicationChannelDataFilter

Modifier and Type	Method and Description
List<IReplicationOrderedPacket>	MultiBucketSingleFileReliableAsyncGroupBacklog.getReliableAsyncPackets(String memberName, int maxSize, IReplicationReliableAsyncGroupBacklog.KeeperMemberState[] keeperMembersState, IReplicationChannelDataFilter dataFilter, PlatformLogicalVersion targetMemberVersion, Logger logger)

Uses of IReplicationChannelDataFilter in com.gigaspaces.internal.cluster.node.impl.backlog.multisourcesinglefile

Methods in com.gigaspaces.internal.cluster.node.impl.backlog.multisourcesinglefile with parameters of type IReplicationChannelDataFilter

Modifier and Type	Method and Description
List<IReplicationOrderedPacket>	MultiSourceSingleFileReliableAsyncGroupBacklog.getReliableAsyncPackets(String memberName, int maxSize, IReplicationReliableAsyncGroupBacklog.KeeperMemberState[] keeperMembersState, IReplicationChannelDataFilter dataFilter, PlatformLogicalVersion targetMemberVersion, Logger logger)

Uses of IReplicationChannelDataFilter in com.gigaspaces.internal.cluster.node.impl.backlog.reliableasync

Methods in com.gigaspaces.internal.cluster.node.impl.backlog.reliableasync with parameters of type IReplicationChannelDataFilter

Modifier and Type	Method and Description
List<IReplicationOrderedPacket>	IReplicationReliableAsyncGroupBacklog.getReliableAsyncPackets(String memberName, int maxSize, IReplicationReliableAsyncGroupBacklog.KeeperMemberState[] keeperMembersState, IReplicationChannelDataFilter dataFilter, PlatformLogicalVersion targetMemberVersion, Logger logger) Gets the next packet for the specified async member that is part of a reliable async group

Uses of IReplicationChannelDataFilter in com.gigaspaces.internal.cluster.node.impl.config

Methods in com.gigaspaces.internal.cluster.node.impl.config that return IReplicationChannelDataFilter

Modifier and Type	Method and Description
IReplicationChannelDataFilter	MemberAddedEvent.getFilter()
IReplicationChannelDataFilter	SourceGroupConfig.getFilter(String memberLookupName)

Methods in com.gigaspaces.internal.cluster.node.impl.config that return types with arguments of type IReplicationChannelDataFilter

Modifier and Type	Method and Description
Map<String,IReplicationChannelDataFilter>	SourceGroupConfig.getFilters()

Methods in com.gigaspaces.internal.cluster.node.impl.config with parameters of type IReplicationChannelDataFilter

Modifier and Type	Method and Description
void	DynamicSourceGroupConfigHolder.addMember(String memberName, IReplicationChannelDataFilter filter, BacklogMemberLimitationConfig memberBacklogLimitations, Object metadata, DynamicSourceGroupMemberLifeCycle lifeCycle)

Method parameters in com.gigaspaces.internal.cluster.node.impl.config with type arguments of type IReplicationChannelDataFilter

Modifier and Type	Method and Description
void	ReplicationNodeConfigBuilder.addKeepersFilters(IReliableAsyncReplicationSettings reliableAsyncSettings, String groupName, List<String> groupMemberNames, Map<String,IReplicationChannelDataFilter> filters, boolean requiresEvictionReplicationProtection)
void	ReplicationNodeConfigBuilder.addKeepersListeners(Map<String,IReplicationChannelDataFilter> filters, DynamicReliableAsyncSourceGroupConfigHolder configHolder)
protected SourceGroupConfig	DynamicSourceGroupConfigHolder.generateNewConfigWithoutMember(String memberName, BacklogConfig backlogConfig, Map<String,IReplicationChannelDataFilter> filters, Map<String,DynamicSourceGroupMemberLifeCycle> lifeCycles, SourceGroupConfig config)
protected SourceGroupConfig	DynamicAsyncSourceGroupConfigHolder.generateNewConfigWithoutMember(String memberName, BacklogConfig backlogConfig, Map<String,IReplicationChannelDataFilter> filters, Map<String,DynamicSourceGroupMemberLifeCycle> lifeCycles, SourceGroupConfig config)
protected SourceGroupConfig	DynamicReliableAsyncSourceGroupConfigHolder.generateNewConfigWithoutMember(String memberName, BacklogConfig backlogConfig, Map<String,IReplicationChannelDataFilter> filters, Map<String,DynamicSourceGroupMemberLifeCycle> lifeCycles, SourceGroupConfig config)
protected SourceGroupConfig	DynamicSourceGroupConfigHolder.generateUpdatedConfig(String memberName, SourceGroupConfig config, BacklogConfig backlogConfig, Map<String,IReplicationChannelDataFilter> filters, Map<String,DynamicSourceGroupMemberLifeCycle> lifeCycles, Object customMetadata)
protected SourceGroupConfig	DynamicAsyncSourceGroupConfigHolder.generateUpdatedConfig(String memberName, SourceGroupConfig config, BacklogConfig backlogConfig, Map<String,IReplicationChannelDataFilter> filters, Map<String,DynamicSourceGroupMemberLifeCycle> lifeCycles, Object customMetadata)
protected SourceGroupConfig	DynamicReliableAsyncSourceGroupConfigHolder.generateUpdatedConfig(String memberName, SourceGroupConfig config, BacklogConfig backlogConfig, Map<String,IReplicationChannelDataFilter> filters, Map<String,DynamicSourceGroupMemberLifeCycle> lifeCycles, Object customMetadata)

Constructors in com.gigaspaces.internal.cluster.node.impl.config with parameters of type IReplicationChannelDataFilter

Constructor and Description
MemberAddedEvent(String memberName, Object customData, BacklogMemberLimitationConfig backlogMemberLimitation, IReplicationChannelDataFilter filter, DynamicSourceGroupMemberLifeCycle lifeCycle)

Constructor parameters in com.gigaspaces.internal.cluster.node.impl.config with type arguments of type IReplicationChannelDataFilter

Constructor and Description
SourceGroupConfig(String groupName, BacklogConfig backlogConfig, GroupConsistencyLevelPolicy groupConsistencyLevelPolicy, Map<String,IReplicationChannelDataFilter> filters, Map<String,DynamicSourceGroupMemberLifeCycle> lifeCycles, Map<String,String[]> membersGrouping, String... membersLookupNames)

Uses of IReplicationChannelDataFilter in com.gigaspaces.internal.cluster.node.impl.groups

Classes in com.gigaspaces.internal.cluster.node.impl.groups that implement IReplicationChannelDataFilter

Modifier and Type	Class and Description
class	AbstractReplicationChannelDataFilter
class	GeneralReplicationChannelDataFilter General replication filter.
class	ReliableAsyncKeeperLruCentralDataSourceReplicationChannelDataFilter If the keeper is in lru with central data source, it will convert update operations to remove, we need to send the update partial with the previous state of the entry if we have view targets

Methods in com.gigaspaces.internal.cluster.node.impl.groups that return IReplicationChannelDataFilter

Modifier and Type	Method and Description
IReplicationChannelDataFilter	IReplicationChannelDataFilterBuilder.createFilter(String name, String groupName, Object... arguments)
IReplicationChannelDataFilter	AbstractReplicationSourceChannel.getDataFilter()

Methods in com.gigaspaces.internal.cluster.node.impl.groups with parameters of type IReplicationChannelDataFilter

Modifier and Type	Method and Description
protected abstract AbstractReplicationSourceChannel	AbstractReplicationSourceGroup.createChannel(String memberLookupName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationChannelDataFilter dataFilter, IReplicationGroupHistory groupHistory, boolean dynamicMember, SourceGroupConfig groupConfig, Object customBacklogMetadata)
static <T extends IReplicationOrderedPacket> T	ReplicationChannelDataFilterHelper.filterPacket(IReplicationChannelDataFilter filter, PlatformLogicalVersion targetMemberVersion, T packet, IReplicationPacketDataProducer dataProducer, IReplicationGroupBacklog groupBacklog, T previousDiscardedPacket, Logger logger, String targetMemberName)
protected static <T extends IReplicationOrderedPacket> T	ReplicationChannelDataFilterHelper.filterSingleEntryDataPacket(IReplicationChannelDataFilter filter, PlatformLogicalVersion targetMemberVersion, T packet, IReplicationPacketDataProducer dataProducer, IReplicationGroupBacklog groupBacklog, T previousDiscardedPacket, Logger logger, String targetMemberName)
protected static <T extends IReplicationOrderedPacket> boolean	ReplicationChannelDataFilterHelper.shouldFilterData(IReplicationChannelDataFilter filter, PlatformLogicalVersion targetMemberVersion, T packet, IReplicationPacketDataProducer dataProducer, Logger logger)

Constructors in com.gigaspaces.internal.cluster.node.impl.groups with parameters of type IReplicationChannelDataFilter

Constructor and Description

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)

Uses of IReplicationChannelDataFilter in com.gigaspaces.internal.cluster.node.impl.groups.async

Methods in com.gigaspaces.internal.cluster.node.impl.groups.async with parameters of type IReplicationChannelDataFilter

Modifier and Type	Method and Description
protected AbstractReplicationSourceChannel	AsyncReplicationSourceGroup.createChannel(String memberLookupName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationChannelDataFilter dataFilter, IReplicationGroupHistory groupHistory, boolean dynamicMember, SourceGroupConfig groupConfig, Object customBacklogMetadata)

Constructors in com.gigaspaces.internal.cluster.node.impl.groups.async with parameters of type IReplicationChannelDataFilter

Constructor and Description
AsyncReplicationSourceChannel(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)
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)

Constructor parameters in com.gigaspaces.internal.cluster.node.impl.groups.async with type arguments of type IReplicationChannelDataFilter

Constructor and Description
AsyncSourceGroupConfig(String groupName, BacklogConfig backlogConfig, GroupConsistencyLevelPolicy groupConsistencyLevelPolicy, Map<String,IReplicationChannelDataFilter> filters, Map<String,DynamicSourceGroupMemberLifeCycle> lifeCycles, Map<String,String[]> membersGrouping, String[] membersLookupNames)

Uses of IReplicationChannelDataFilter in com.gigaspaces.internal.cluster.node.impl.groups.reliableasync

Classes in com.gigaspaces.internal.cluster.node.impl.groups.reliableasync that implement IReplicationChannelDataFilter

Modifier and Type	Class and Description
class	GatewayChannelDataFilter
class	MirrorChannelDataFilter
class	ReliableAsyncChannelDataFilter

Methods in com.gigaspaces.internal.cluster.node.impl.groups.reliableasync with parameters of type IReplicationChannelDataFilter

Modifier and Type	Method and Description
protected AbstractReplicationSourceChannel	ReliableAsyncReplicationSourceGroup.createChannel(String memberLookupName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationChannelDataFilter dataFilter, IReplicationGroupHistory groupHistory, boolean dynamicMember, SourceGroupConfig groupConfig, Object customBacklogMetadata)

Constructors in com.gigaspaces.internal.cluster.node.impl.groups.reliableasync with parameters of type IReplicationChannelDataFilter

Constructor and Description
ReliableAsyncMemberData(BacklogMemberLimitationConfig memberBacklogLimitationConfig, IReplicationChannelDataFilter memberFilter, DynamicSourceGroupMemberLifeCycle memberLifeCycle, RouterStubHolder routerStubHolder, AsyncChannelConfig asyncChannelConfig)
ReliableAsyncReplicationSourceChannel(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)

Constructor parameters in com.gigaspaces.internal.cluster.node.impl.groups.reliableasync with type arguments of type IReplicationChannelDataFilter

Constructor and Description

ReliableAsyncSourceGroupConfig(String groupName, BacklogConfig backlogConfig, GroupConsistencyLevelPolicy groupConsistencyLevelPolicy, Map<String,IReplicationChannelDataFilter> filters, Map<String,DynamicSourceGroupMemberLifeCycle> lifeCycles, Map<String,String[]> membersGrouping, String[] syncMembersLookupNames, String[] asyncMembersLookupNames, int backlogCompletionBatchSize, long completionNotifierInterval, long completionNotifierPacketsThreshold)

Uses of IReplicationChannelDataFilter in com.gigaspaces.internal.cluster.node.impl.groups.sync

Methods in com.gigaspaces.internal.cluster.node.impl.groups.sync with parameters of type IReplicationChannelDataFilter

Modifier and Type	Method and Description
protected AbstractReplicationSourceChannel	SyncReplicationSourceGroup.createChannel(String memberLookupName, IReplicationRouter replicationRouter, IReplicationMonitoredConnection connection, IReplicationChannelDataFilter dataFilter, IReplicationGroupHistory groupHistory, boolean dynamicMember, SourceGroupConfig groupConfig, Object customBacklogMetadata)

Constructors in com.gigaspaces.internal.cluster.node.impl.groups.sync with parameters of type IReplicationChannelDataFilter

Constructor and Description

SyncReplicationSourceChannel(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)

Uses of IReplicationChannelDataFilter in com.gigaspaces.internal.cluster.node.impl.notification

Classes in com.gigaspaces.internal.cluster.node.impl.notification that implement IReplicationChannelDataFilter

Modifier and Type	Class and Description
class	NotificationReplicationChannelDataFilter

Uses of IReplicationChannelDataFilter in com.gigaspaces.internal.cluster.node.impl.view

Classes in com.gigaspaces.internal.cluster.node.impl.view that implement IReplicationChannelDataFilter

Modifier and Type	Class and Description
class	ViewReplicationChannelDataFilter

Uses of IReplicationChannelDataFilter in com.gigaspaces.internal.server.space.replication

Methods in com.gigaspaces.internal.server.space.replication that return IReplicationChannelDataFilter

Modifier and Type	Method and Description
IReplicationChannelDataFilter	SpaceReplicationChannelDataFilterBuilder.createFilter(String name, String groupName, Object... arguments)