Package org.infinispan.commands

Class CommandsFactoryImpl

java.lang.Object

org.infinispan.commands.CommandsFactoryImpl

All Implemented Interfaces:

CommandsFactory

public class CommandsFactoryImpl
extends Object
implements CommandsFactory

Since:

4.0

Author:

Mircea.Markus@jboss.com, Galder Zamarreño, Sanne Grinovero <sanne@hibernate.org> (C) 2011 Red Hat Inc.

Constructor Summary

Constructors

Constructor	Description
CommandsFactoryImpl()

Method Summary

Modifier and Type	Method	Description
org.infinispan.commands.write.BackupAckCommand	buildBackupAckCommand(long id, int topologyId)
org.infinispan.commands.write.BackupMultiKeyAckCommand	buildBackupMultiKeyAckCommand(long id, int segment, int topologyId)
org.infinispan.commands.triangle.BackupNoopCommand	buildBackupNoopCommand()
org.infinispan.reactive.publisher.impl.commands.batch.CancelPublisherCommand	buildCancelPublisherCommand(String requestId)
org.infinispan.commands.remote.CheckTransactionRpcCommand	buildCheckTransactionRpcCommand(Collection<GlobalTransaction> globalTransactions)
org.infinispan.commands.write.ClearCommand	buildClearCommand(long flagsBitSet)	Builds a ClearCommand
org.infinispan.commands.remote.ClusteredGetAllCommand	buildClusteredGetAllCommand(List<?> keys, long flagsBitSet, GlobalTransaction gtx)	Builds a ClusteredGetAllCommand, which is a remote lookup command
org.infinispan.commands.remote.ClusteredGetCommand	buildClusteredGetCommand(Object key, Integer segment, long flagsBitSet)	Builds a ClusteredGetCommand, which is a remote lookup command
org.infinispan.commands.tx.CommitCommand	buildCommitCommand(GlobalTransaction gtx)	Builds a CommitCommand
org.infinispan.commands.remote.recovery.CompleteTransactionCommand	buildCompleteTransactionCommand(XidImpl xid, boolean commit)	Builds a CompleteTransactionCommand command.
org.infinispan.commands.write.ComputeCommand	buildComputeCommand(Object key, BiFunction mappingFunction, boolean computeIfPresent, int segment, Metadata metadata, long flagsBitSet)	Builds a ComputeCommand
org.infinispan.commands.write.ComputeIfAbsentCommand	buildComputeIfAbsentCommand(Object key, Function mappingFunction, int segment, Metadata metadata, long flagsBitSet)	Builds a ComputeIfAbsentCommand
org.infinispan.commands.statetransfer.ConflictResolutionStartCommand	buildConflictResolutionStartCommand(int topologyId, IntSet segments)
<K, V, R> org.infinispan.reactive.publisher.impl.commands.reduction.ReductionPublisherRequestCommand<K>	buildEntryReductionPublisherCommand(boolean parallelStream, DeliveryGuarantee deliveryGuarantee, IntSet segments, Set<K> keys, Set<K> excludedKeys, long explicitFlags, Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
org.infinispan.commands.read.EntrySetCommand	buildEntrySetCommand(long flagsBitSet)	Builds a EntrySetCommand
org.infinispan.commands.write.EvictCommand	buildEvictCommand(Object key, int segment, long flagsBitSet)	Builds an EvictCommand
org.infinispan.commands.write.ExceptionAckCommand	buildExceptionAckCommand(long id, Throwable throwable, int topologyId)
org.infinispan.commands.read.GetAllCommand	buildGetAllCommand(Collection<?> keys, long flagsBitSet, boolean returnEntries)	Builds a GetAllCommand
org.infinispan.commands.read.GetCacheEntryCommand	buildGetCacheEntryCommand(Object key, int segment, long flagsBitSet)	Builds a GetCacheEntryCommand
org.infinispan.commands.remote.recovery.GetInDoubtTransactionsCommand	buildGetInDoubtTransactionsCommand()	Builds a GetInDoubtTransactionsCommand.
org.infinispan.commands.remote.recovery.GetInDoubtTxInfoCommand	buildGetInDoubtTxInfoCommand()
org.infinispan.commands.read.GetKeyValueCommand	buildGetKeyValueCommand(Object key, int segment, long flagsBitSet)	Builds a GetKeyValueCommand
<K, I, R> org.infinispan.reactive.publisher.impl.commands.batch.InitialPublisherCommand<K,I,R>	buildInitialPublisherCommand(String requestId, DeliveryGuarantee deliveryGuarantee, int batchSize, IntSet segments, Set<K> keys, Set<K> excludedKeys, long explicitFlags, boolean entryStream, boolean trackKeys, Function<? super org.reactivestreams.Publisher<I>,? extends org.reactivestreams.Publisher<R>> transformer)
org.infinispan.commands.write.InvalidateCommand	buildInvalidateCommand(long flagsBitSet, Object... keys)	Builds an InvalidateCommand
org.infinispan.commands.write.InvalidateCommand	buildInvalidateFromL1Command(long flagsBitSet, Collection<Object> keys)	Builds an InvalidateFromL1Command
org.infinispan.commands.write.InvalidateCommand	buildInvalidateFromL1Command(Address origin, long flagsBitSet, Collection<Object> keys)
org.infinispan.commands.write.InvalidateVersionsCommand	buildInvalidateVersionsCommand(int topologyId, Object[] keys, int[] topologyIds, long[] versions, boolean removed)
org.infinispan.commands.irac.IracCleanupKeysCommand	buildIracCleanupKeyCommand(Collection<? extends IracManagerKeyInfo> state)
IracClearKeysRequest	buildIracClearKeysCommand()
org.infinispan.commands.irac.IracMetadataRequestCommand	buildIracMetadataRequestCommand(int segment, IracEntryVersion versionSeen)
org.infinispan.commands.write.IracPutKeyValueCommand	buildIracPutKeyValueCommand(Object key, int segment, Object value, Metadata metadata, PrivateMetadata privateMetadata)
IracPutManyRequest	buildIracPutManyCommand(int capacity)
org.infinispan.commands.irac.IracRequestStateCommand	buildIracRequestStateCommand(IntSet segments)
org.infinispan.commands.irac.IracStateResponseCommand	buildIracStateResponseCommand(int capacity)
IracTombstoneCheckRequest	buildIracTombstoneCheckRequest(List<Object> keys)
org.infinispan.commands.irac.IracTombstoneCleanupCommand	buildIracTombstoneCleanupCommand(int maxCapacity)
org.infinispan.commands.irac.IracTombstonePrimaryCheckCommand	buildIracTombstonePrimaryCheckCommand(Collection<IracTombstoneInfo> tombstones)
org.infinispan.commands.irac.IracTombstoneRemoteSiteCheckCommand	buildIracTombstoneRemoteSiteCheckCommand(List<Object> keys)
org.infinispan.commands.irac.IracTombstoneStateResponseCommand	buildIracTombstoneStateResponseCommand(Collection<IracTombstoneInfo> state)
IracTouchKeyRequest	buildIracTouchCommand(Object key)
org.infinispan.commands.irac.IracUpdateVersionCommand	buildIracUpdateVersionCommand(Map<Integer,IracEntryVersion> segmentsVersion)
<K, R> org.infinispan.reactive.publisher.impl.commands.reduction.ReductionPublisherRequestCommand<K>	buildKeyReductionPublisherCommand(boolean parallelStream, DeliveryGuarantee deliveryGuarantee, IntSet segments, Set<K> keys, Set<K> excludedKeys, long explicitFlags, Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer, Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)
org.infinispan.commands.read.KeySetCommand	buildKeySetCommand(long flagsBitSet)	Builds a KeySetCommand
org.infinispan.commands.control.LockControlCommand	buildLockControlCommand(Object key, long flagsBitSet, GlobalTransaction gtx)	Same as CommandsFactory.buildLockControlCommand(Collection, long, GlobalTransaction) but for locking a single key vs a collection of keys.
org.infinispan.commands.control.LockControlCommand	buildLockControlCommand(Collection<?> keys, long flagsBitSet)
org.infinispan.commands.control.LockControlCommand	buildLockControlCommand(Collection<?> keys, long flagsBitSet, GlobalTransaction gtx)	Builds a LockControlCommand to control explicit remote locking
<K, V> MultiClusterEventCommand<K,V>	buildMultiClusterEventCommand(Map<UUID,Collection<ClusterEvent<K,V>>> events)
org.infinispan.commands.triangle.MultiEntriesFunctionalBackupWriteCommand	buildMultiEntriesFunctionalBackupWriteCommand()
org.infinispan.commands.triangle.MultiKeyFunctionalBackupWriteCommand	buildMultiKeyFunctionalBackupWriteCommand()
org.infinispan.reactive.publisher.impl.commands.batch.NextPublisherCommand	buildNextPublisherCommand(String requestId)
org.infinispan.commands.tx.PrepareCommand	buildPrepareCommand(GlobalTransaction gtx, List<org.infinispan.commands.write.WriteCommand> modifications, boolean onePhaseCommit)	Builds a PrepareCommand
org.infinispan.commands.write.PutKeyValueCommand	buildPutKeyValueCommand(Object key, Object value, int segment, Metadata metadata, long flagsBitSet, boolean returnEntry)
org.infinispan.commands.triangle.PutMapBackupWriteCommand	buildPutMapBackupWriteCommand()
org.infinispan.commands.write.PutMapCommand	buildPutMapCommand(Map<?,?> map, Metadata metadata, long flagsBitSet)	Builds a PutMapCommand
<K, V, R> org.infinispan.commands.functional.ReadOnlyKeyCommand<K,V,R>	buildReadOnlyKeyCommand(Object key, Function<EntryView.ReadEntryView<K,V>,R> f, int segment, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)
<K, V, R> org.infinispan.commands.functional.ReadOnlyManyCommand<K,V,R>	buildReadOnlyManyCommand(Collection<?> keys, Function<EntryView.ReadEntryView<K,V>,R> f, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)
<K, V, R> org.infinispan.commands.functional.ReadWriteKeyCommand<K,V,R>	buildReadWriteKeyCommand(Object key, Function<EntryView.ReadWriteEntryView<K,V>,R> f, int segment, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)
<K, V, T, R> org.infinispan.commands.functional.ReadWriteKeyValueCommand<K,V,T,R>	buildReadWriteKeyValueCommand(Object key, Object argument, BiFunction<T,EntryView.ReadWriteEntryView<K,V>,R> f, int segment, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)
<K, V, R> org.infinispan.commands.functional.ReadWriteManyCommand<K,V,R>	buildReadWriteManyCommand(Collection<?> keys, Function<EntryView.ReadWriteEntryView<K,V>,R> f, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)
<K, V, T, R> org.infinispan.commands.functional.ReadWriteManyEntriesCommand<K,V,T,R>	buildReadWriteManyEntriesCommand(Map<?,?> entries, BiFunction<T,EntryView.ReadWriteEntryView<K,V>,R> f, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)
org.infinispan.commands.write.RemoveCommand	buildRemoveCommand(Object key, Object value, int segment, long flagsBitSet, boolean returnEntry)
org.infinispan.commands.write.RemoveExpiredCommand	buildRemoveExpiredCommand(Object key, Object value, int segment, long flagsBitSet)	Builds an expired remove command that is used to remove only a specific entry when it expires via maxIdle
org.infinispan.commands.write.RemoveExpiredCommand	buildRemoveExpiredCommand(Object key, Object value, int segment, Long lifespan, long flagsBitSet)	Builds an expired remove command that is used to remove only a specific entry when it expires via lifespan
org.infinispan.commands.remote.RenewBiasCommand	buildRenewBiasCommand(Object[] keys)
org.infinispan.commands.write.ReplaceCommand	buildReplaceCommand(Object key, Object oldValue, Object newValue, int segment, Metadata metadata, long flagsBitSet, boolean returnEntry)	Builds a ReplaceCommand
org.infinispan.commands.remote.RevokeBiasCommand	buildRevokeBiasCommand(Address ackTarget, long id, int topologyId, Collection<Object> keys)
org.infinispan.commands.tx.RollbackCommand	buildRollbackCommand(GlobalTransaction gtx)	Builds a RollbackCommand
org.infinispan.commands.statetransfer.ScatteredStateConfirmRevokedCommand	buildScatteredStateConfirmRevokeCommand(int topologyId, IntSet segments)
org.infinispan.commands.statetransfer.ScatteredStateGetKeysCommand	buildScatteredStateGetKeysCommand(int topologyId, IntSet segments)
org.infinispan.commands.triangle.SingleKeyBackupWriteCommand	buildSingleKeyBackupWriteCommand()
org.infinispan.commands.triangle.SingleKeyFunctionalBackupWriteCommand	buildSingleKeyFunctionalBackupWriteCommand()
org.infinispan.commands.remote.SingleRpcCommand	buildSingleRpcCommand(VisitableCommand call)	Builds a SingleRpcCommand "envelope" containing a single ReplicableCommand
org.infinispan.xsite.SingleXSiteRpcCommand	buildSingleXSiteRpcCommand(VisitableCommand command)	Builds SingleRpcCommand used to perform VisitableCommand on the backup site,
org.infinispan.commands.read.SizeCommand	buildSizeCommand(IntSet segments, long flagsBitSet)	Builds a SizeCommand
org.infinispan.commands.statetransfer.StateResponseCommand	buildStateResponseCommand(int topologyId, Collection<org.infinispan.statetransfer.StateChunk> stateChunks, boolean applyState, boolean pushTransfer)	Builds a StateResponseCommand used for pushing cache entries to another node.
org.infinispan.commands.statetransfer.StateTransferCancelCommand	buildStateTransferCancelCommand(int topologyId, IntSet segments)
org.infinispan.commands.statetransfer.StateTransferGetListenersCommand	buildStateTransferGetListenersCommand(int topologyId)
org.infinispan.commands.statetransfer.StateTransferGetTransactionsCommand	buildStateTransferGetTransactionsCommand(int topologyId, IntSet segments)
org.infinispan.commands.statetransfer.StateTransferStartCommand	buildStateTransferStartCommand(int topologyId, IntSet segments)
TouchCommand	buildTouchCommand(Object key, int segment, boolean touchEvenIfExpired, long flagBitSet)
org.infinispan.commands.remote.recovery.TxCompletionNotificationCommand	buildTxCompletionNotificationCommand(long internalId)
org.infinispan.commands.remote.recovery.TxCompletionNotificationCommand	buildTxCompletionNotificationCommand(XidImpl xid, GlobalTransaction globalTransaction)	Builds a TxCompletionNotificationCommand.
<K, V, R> org.infinispan.commands.functional.TxReadOnlyKeyCommand<K,V,R>	buildTxReadOnlyKeyCommand(Object key, Function<EntryView.ReadEntryView<K,V>,R> f, List<org.infinispan.commands.functional.Mutation<K,V,?>> mutations, int segment, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)
<K, V, R> org.infinispan.commands.functional.TxReadOnlyManyCommand<K,V,R>	buildTxReadOnlyManyCommand(Collection<?> keys, List<List<org.infinispan.commands.functional.Mutation<K,V,?>>> mutations, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)
org.infinispan.commands.tx.VersionedCommitCommand	buildVersionedCommitCommand(GlobalTransaction gtx)	Builds a VersionedCommitCommand
org.infinispan.commands.tx.VersionedPrepareCommand	buildVersionedPrepareCommand(GlobalTransaction gtx, List<org.infinispan.commands.write.WriteCommand> modifications, boolean onePhase)	Builds a VersionedPrepareCommand
<K, V> org.infinispan.commands.functional.WriteOnlyKeyCommand<K,V>	buildWriteOnlyKeyCommand(Object key, Consumer<EntryView.WriteEntryView<K,V>> f, int segment, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)
<K, V, T> org.infinispan.commands.functional.WriteOnlyKeyValueCommand<K,V,T>	buildWriteOnlyKeyValueCommand(Object key, Object argument, BiConsumer<T,EntryView.WriteEntryView<K,V>> f, int segment, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)
<K, V> org.infinispan.commands.functional.WriteOnlyManyCommand<K,V>	buildWriteOnlyManyCommand(Collection<?> keys, Consumer<EntryView.WriteEntryView<K,V>> f, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)
<K, V, T> org.infinispan.commands.functional.WriteOnlyManyEntriesCommand<K,V,T>	buildWriteOnlyManyEntriesCommand(Map<?,?> arguments, BiConsumer<T,EntryView.WriteEntryView<K,V>> f, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)
XSiteAmendOfflineStatusCommand	buildXSiteAmendOfflineStatusCommand(String siteName, Integer afterFailures, Long minTimeToWait)
XSiteAutoTransferStatusCommand	buildXSiteAutoTransferStatusCommand(String site)
XSiteBringOnlineCommand	buildXSiteBringOnlineCommand(String siteName)
XSiteOfflineStatusCommand	buildXSiteOfflineStatusCommand(String siteName)
XSiteSetStateTransferModeCommand	buildXSiteSetStateTransferModeCommand(String site, XSiteStateTransferMode mode)
XSiteStatePushCommand	buildXSiteStatePushCommand(XSiteState[] chunk)	Builds XSiteStatePushCommand used to transfer a single chunk of data between sites.
XSiteStatePushRequest	buildXSiteStatePushRequest(XSiteState[] chunk, long timeoutMillis)
XSiteStateTransferCancelSendCommand	buildXSiteStateTransferCancelSendCommand(String siteName)
XSiteStateTransferClearStatusCommand	buildXSiteStateTransferClearStatusCommand()
XSiteStateTransferControlRequest	buildXSiteStateTransferControlRequest(boolean startReceiving)
XSiteStateTransferFinishReceiveCommand	buildXSiteStateTransferFinishReceiveCommand(String siteName)
XSiteStateTransferFinishSendCommand	buildXSiteStateTransferFinishSendCommand(String siteName, boolean statusOk)
XSiteStateTransferRestartSendingCommand	buildXSiteStateTransferRestartSendingCommand(String siteName, int topologyId)
XSiteStateTransferStartReceiveCommand	buildXSiteStateTransferStartReceiveCommand(String siteName)
XSiteStateTransferStartSendCommand	buildXSiteStateTransferStartSendCommand(String siteName, int topologyId)
XSiteStateTransferStatusRequestCommand	buildXSiteStateTransferStatusRequestCommand()
XSiteStatusCommand	buildXSiteStatusCommand()
XSiteTakeOfflineCommand	buildXSiteTakeOfflineCommand(String siteName)
String	getCacheName()	Retrieves the cache name this CommandFactory is set up to construct commands for.
void	initializeReplicableCommand(ReplicableCommand c, boolean isRemote)	Initializes a ReplicableCommand read from a data stream with components specific to the target cache instance.
void	start()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.commands.CommandsFactory

buildPutKeyValueCommand, buildRemoveCommand, buildReplaceCommand, buildSingleRpcCommand

Constructor Details

CommandsFactoryImpl

public CommandsFactoryImpl()

Method Details

start

public void start()

buildPutKeyValueCommand

public org.infinispan.commands.write.PutKeyValueCommand buildPutKeyValueCommand(Object key,
 Object value,
 int segment,
 Metadata metadata,
 long flagsBitSet,
 boolean returnEntry)

Specified by:

buildPutKeyValueCommand in interface CommandsFactory

buildRemoveCommand

public org.infinispan.commands.write.RemoveCommand buildRemoveCommand(Object key,
 Object value,
 int segment,
 long flagsBitSet,
 boolean returnEntry)

Specified by:

buildRemoveCommand in interface CommandsFactory

buildInvalidateCommand

public org.infinispan.commands.write.InvalidateCommand buildInvalidateCommand(long flagsBitSet,
 Object... keys)

Description copied from interface: CommandsFactory

Builds an InvalidateCommand

Specified by:

buildInvalidateCommand in interface CommandsFactory

Parameters:

flagsBitSet - Command flags provided by cache

keys - keys to invalidate

Returns:

an InvalidateCommand

buildInvalidateFromL1Command

public org.infinispan.commands.write.InvalidateCommand buildInvalidateFromL1Command(long flagsBitSet,
 Collection<Object> keys)

Description copied from interface: CommandsFactory

Builds an InvalidateFromL1Command

Specified by:

buildInvalidateFromL1Command in interface CommandsFactory

Parameters:

flagsBitSet - Command flags provided by cache

keys - keys to invalidate

Returns:

an InvalidateFromL1Command

buildInvalidateFromL1Command

public org.infinispan.commands.write.InvalidateCommand buildInvalidateFromL1Command(Address origin,
 long flagsBitSet,
 Collection<Object> keys)

Specified by:

buildInvalidateFromL1Command in interface CommandsFactory

See Also:

• CommandsFactory.buildInvalidateFromL1Command(long, Collection)

buildRemoveExpiredCommand

public org.infinispan.commands.write.RemoveExpiredCommand buildRemoveExpiredCommand(Object key,
 Object value,
 int segment,
 Long lifespan,
 long flagsBitSet)

Description copied from interface: CommandsFactory

Builds an expired remove command that is used to remove only a specific entry when it expires via lifespan

Specified by:

buildRemoveExpiredCommand in interface CommandsFactory

Parameters:

key - the key of the expired entry

value - the value of the entry when it was expired

segment - the segment of the given key

lifespan - the lifespan that expired from the command

flagsBitSet - Command flags provided by cache

Returns:

a RemovedExpiredCommand

buildRemoveExpiredCommand

public org.infinispan.commands.write.RemoveExpiredCommand buildRemoveExpiredCommand(Object key,
 Object value,
 int segment,
 long flagsBitSet)

Description copied from interface: CommandsFactory

Builds an expired remove command that is used to remove only a specific entry when it expires via maxIdle

Specified by:

buildRemoveExpiredCommand in interface CommandsFactory

Parameters:

key - the key of the expired entry

value - the value of the entry when it was expired

segment - the segment of the given key

flagsBitSet - Command flags provided by cache

Returns:

a RemovedExpiredCommand

buildReplaceCommand

public org.infinispan.commands.write.ReplaceCommand buildReplaceCommand(Object key,
 Object oldValue,
 Object newValue,
 int segment,
 Metadata metadata,
 long flagsBitSet,
 boolean returnEntry)

Description copied from interface: CommandsFactory

Builds a ReplaceCommand

Specified by:

buildReplaceCommand in interface CommandsFactory

Parameters:

key - key to replace

oldValue - existing value to check for if conditional, null if unconditional.

newValue - value to replace with

segment - the segment of the given key

metadata - metadata of entry

flagsBitSet - Command flags provided by cache

returnEntry - true if the CacheEntry is the command response, otherwise returns previous value.

Returns:

a ReplaceCommand

buildComputeCommand

public org.infinispan.commands.write.ComputeCommand buildComputeCommand(Object key,
 BiFunction mappingFunction,
 boolean computeIfPresent,
 int segment,
 Metadata metadata,
 long flagsBitSet)

Description copied from interface: CommandsFactory

Builds a ComputeCommand

Specified by:

buildComputeCommand in interface CommandsFactory

Parameters:

key - key to compute if this key is absent

mappingFunction - BiFunction for the key and the value

computeIfPresent - flag to apply as computeIfPresent mode

segment - the segment of the given key

metadata - metadata of entry

flagsBitSet - Command flags provided by cache

Returns:

a ComputeCommand

buildComputeIfAbsentCommand

public org.infinispan.commands.write.ComputeIfAbsentCommand buildComputeIfAbsentCommand(Object key,
 Function mappingFunction,
 int segment,
 Metadata metadata,
 long flagsBitSet)

Description copied from interface: CommandsFactory

Builds a ComputeIfAbsentCommand

Specified by:

buildComputeIfAbsentCommand in interface CommandsFactory

Parameters:

key - key to compute if this key is absent

mappingFunction - mappingFunction for the key

segment - the segment of the given key

metadata - metadata of entry

flagsBitSet - Command flags provided by cache

Returns:

a ComputeCommand

buildSizeCommand

public org.infinispan.commands.read.SizeCommand buildSizeCommand(IntSet segments,
 long flagsBitSet)

Description copied from interface: CommandsFactory

Builds a SizeCommand

Specified by:

buildSizeCommand in interface CommandsFactory

flagsBitSet - Command flags provided by cache

Returns:

a SizeCommand

buildKeySetCommand

public org.infinispan.commands.read.KeySetCommand buildKeySetCommand(long flagsBitSet)

Description copied from interface: CommandsFactory

Builds a KeySetCommand

Specified by:

buildKeySetCommand in interface CommandsFactory

Parameters:

flagsBitSet - Command flags provided by cache

Returns:

a KeySetCommand

buildEntrySetCommand

public org.infinispan.commands.read.EntrySetCommand buildEntrySetCommand(long flagsBitSet)

Description copied from interface: CommandsFactory

Builds a EntrySetCommand

Specified by:

buildEntrySetCommand in interface CommandsFactory

Parameters:

flagsBitSet - Command flags provided by cache

Returns:

a EntrySetCommand

buildGetKeyValueCommand

public org.infinispan.commands.read.GetKeyValueCommand buildGetKeyValueCommand(Object key,
 int segment,
 long flagsBitSet)

Description copied from interface: CommandsFactory

Builds a GetKeyValueCommand

Specified by:

buildGetKeyValueCommand in interface CommandsFactory

Parameters:

key - key to get

segment - the segment of the given key

flagsBitSet - Command flags provided by cache

Returns:

a GetKeyValueCommand

buildGetAllCommand

public org.infinispan.commands.read.GetAllCommand buildGetAllCommand(Collection<?> keys,
 long flagsBitSet,
 boolean returnEntries)

Description copied from interface: CommandsFactory

Builds a GetAllCommand

Specified by:

buildGetAllCommand in interface CommandsFactory

Parameters:

keys - keys to get

flagsBitSet - Command flags provided by cache

returnEntries - boolean indicating whether entire cache entries are returned, otherwise return just the value parts

Returns:

a GetKeyValueCommand

buildPutMapCommand

public org.infinispan.commands.write.PutMapCommand buildPutMapCommand(Map<?,?> map,
 Metadata metadata,
 long flagsBitSet)

Description copied from interface: CommandsFactory

Builds a PutMapCommand

Specified by:

buildPutMapCommand in interface CommandsFactory

Parameters:

map - map containing key/value entries to put

metadata - metadata of entry

flagsBitSet - Command flags provided by cache

Returns:

a PutMapCommand

buildClearCommand

public org.infinispan.commands.write.ClearCommand buildClearCommand(long flagsBitSet)

Description copied from interface: CommandsFactory

Builds a ClearCommand

Specified by:

buildClearCommand in interface CommandsFactory

Parameters:

flagsBitSet - Command flags provided by cache

Returns:

a ClearCommand

buildEvictCommand

public org.infinispan.commands.write.EvictCommand buildEvictCommand(Object key,
 int segment,
 long flagsBitSet)

Description copied from interface: CommandsFactory

Builds an EvictCommand

Specified by:

buildEvictCommand in interface CommandsFactory

Parameters:

key - key to evict

segment - the segment for the key

flagsBitSet - Command flags provided by cache

Returns:

an EvictCommand

buildPrepareCommand

public org.infinispan.commands.tx.PrepareCommand buildPrepareCommand(GlobalTransaction gtx,
 List<org.infinispan.commands.write.WriteCommand> modifications,
 boolean onePhaseCommit)

Description copied from interface: CommandsFactory

Builds a PrepareCommand

Specified by:

buildPrepareCommand in interface CommandsFactory

Parameters:

gtx - global transaction associated with the prepare

modifications - list of modifications

onePhaseCommit - is this a one-phase or two-phase transaction?

Returns:

a PrepareCommand

buildVersionedPrepareCommand

public org.infinispan.commands.tx.VersionedPrepareCommand buildVersionedPrepareCommand(GlobalTransaction gtx,
 List<org.infinispan.commands.write.WriteCommand> modifications,
 boolean onePhase)

Description copied from interface: CommandsFactory

Builds a VersionedPrepareCommand

Specified by:

buildVersionedPrepareCommand in interface CommandsFactory

Parameters:

gtx - global transaction associated with the prepare

modifications - list of modifications

Returns:

a VersionedPrepareCommand

buildCommitCommand

public org.infinispan.commands.tx.CommitCommand buildCommitCommand(GlobalTransaction gtx)

Description copied from interface: CommandsFactory

Builds a CommitCommand

Specified by:

buildCommitCommand in interface CommandsFactory

Parameters:

gtx - global transaction associated with the commit

Returns:

a CommitCommand

buildVersionedCommitCommand

public org.infinispan.commands.tx.VersionedCommitCommand buildVersionedCommitCommand(GlobalTransaction gtx)

Description copied from interface: CommandsFactory

Builds a VersionedCommitCommand

Specified by:

buildVersionedCommitCommand in interface CommandsFactory

Parameters:

gtx - global transaction associated with the commit

Returns:

a VersionedCommitCommand

buildRollbackCommand

public org.infinispan.commands.tx.RollbackCommand buildRollbackCommand(GlobalTransaction gtx)

Description copied from interface: CommandsFactory

Builds a RollbackCommand

Specified by:

buildRollbackCommand in interface CommandsFactory

Parameters:

gtx - global transaction associated with the rollback

Returns:

a RollbackCommand

buildSingleRpcCommand

public org.infinispan.commands.remote.SingleRpcCommand buildSingleRpcCommand(VisitableCommand call)

Description copied from interface: CommandsFactory

Builds a SingleRpcCommand "envelope" containing a single ReplicableCommand

Specified by:

buildSingleRpcCommand in interface CommandsFactory

Parameters:

call - VisitableCommand to include in the envelope

Returns:

a SingleRpcCommand

buildClusteredGetCommand

public org.infinispan.commands.remote.ClusteredGetCommand buildClusteredGetCommand(Object key,
 Integer segment,
 long flagsBitSet)

Description copied from interface: CommandsFactory

Builds a ClusteredGetCommand, which is a remote lookup command

Specified by:

buildClusteredGetCommand in interface CommandsFactory

Parameters:

key - key to look up

segment - the segment for the key or null if it should be computed on the remote node

flagsBitSet - Command flags provided by cache

Returns:

a ClusteredGetCommand

initializeReplicableCommand

public void initializeReplicableCommand(ReplicableCommand c,
 boolean isRemote)

Description copied from interface: CommandsFactory

Initializes a ReplicableCommand read from a data stream with components specific to the target cache instance.

Implementations should also be deep, in that if the command contains other commands, these should be recursed into.

Specified by:

initializeReplicableCommand in interface CommandsFactory

Parameters:

isRemote - true if the command is deserialized and is executed remote.

c - command to initialize. Cannot be null.

buildLockControlCommand

public org.infinispan.commands.control.LockControlCommand buildLockControlCommand(Collection<?> keys,
 long flagsBitSet,
 GlobalTransaction gtx)

Description copied from interface: CommandsFactory

Builds a LockControlCommand to control explicit remote locking

Specified by:

buildLockControlCommand in interface CommandsFactory

Parameters:

keys - keys to lock

flagsBitSet - Command flags provided by cache

Returns:

a LockControlCommand

buildLockControlCommand

public org.infinispan.commands.control.LockControlCommand buildLockControlCommand(Object key,
 long flagsBitSet,
 GlobalTransaction gtx)

Description copied from interface: CommandsFactory

Same as CommandsFactory.buildLockControlCommand(Collection, long, GlobalTransaction) but for locking a single key vs a collection of keys.

Specified by:

buildLockControlCommand in interface CommandsFactory

buildLockControlCommand

public org.infinispan.commands.control.LockControlCommand buildLockControlCommand(Collection<?> keys,
 long flagsBitSet)

Specified by:

buildLockControlCommand in interface CommandsFactory

buildConflictResolutionStartCommand

public org.infinispan.commands.statetransfer.ConflictResolutionStartCommand buildConflictResolutionStartCommand(int topologyId,
 IntSet segments)

Specified by:

buildConflictResolutionStartCommand in interface CommandsFactory

buildScatteredStateConfirmRevokeCommand

public org.infinispan.commands.statetransfer.ScatteredStateConfirmRevokedCommand buildScatteredStateConfirmRevokeCommand(int topologyId,
 IntSet segments)

Specified by:

buildScatteredStateConfirmRevokeCommand in interface CommandsFactory

buildScatteredStateGetKeysCommand

public org.infinispan.commands.statetransfer.ScatteredStateGetKeysCommand buildScatteredStateGetKeysCommand(int topologyId,
 IntSet segments)

Specified by:

buildScatteredStateGetKeysCommand in interface CommandsFactory

buildStateTransferCancelCommand

public org.infinispan.commands.statetransfer.StateTransferCancelCommand buildStateTransferCancelCommand(int topologyId,
 IntSet segments)

Specified by:

buildStateTransferCancelCommand in interface CommandsFactory

buildStateTransferGetListenersCommand

public org.infinispan.commands.statetransfer.StateTransferGetListenersCommand buildStateTransferGetListenersCommand(int topologyId)

Specified by:

buildStateTransferGetListenersCommand in interface CommandsFactory

buildStateTransferGetTransactionsCommand

public org.infinispan.commands.statetransfer.StateTransferGetTransactionsCommand buildStateTransferGetTransactionsCommand(int topologyId,
 IntSet segments)

Specified by:

buildStateTransferGetTransactionsCommand in interface CommandsFactory

buildStateTransferStartCommand

public org.infinispan.commands.statetransfer.StateTransferStartCommand buildStateTransferStartCommand(int topologyId,
 IntSet segments)

Specified by:

buildStateTransferStartCommand in interface CommandsFactory

buildStateResponseCommand

public org.infinispan.commands.statetransfer.StateResponseCommand buildStateResponseCommand(int topologyId,
 Collection<org.infinispan.statetransfer.StateChunk> stateChunks,
 boolean applyState,
 boolean pushTransfer)

Description copied from interface: CommandsFactory

Builds a StateResponseCommand used for pushing cache entries to another node.

Specified by:

buildStateResponseCommand in interface CommandsFactory

getCacheName

public String getCacheName()

Description copied from interface: CommandsFactory

Retrieves the cache name this CommandFactory is set up to construct commands for.

Specified by:

getCacheName in interface CommandsFactory

Returns:

the name of the cache this CommandFactory is set up to construct commands for.

buildGetInDoubtTransactionsCommand

public org.infinispan.commands.remote.recovery.GetInDoubtTransactionsCommand buildGetInDoubtTransactionsCommand()

Description copied from interface: CommandsFactory

Builds a GetInDoubtTransactionsCommand.

Specified by:

buildGetInDoubtTransactionsCommand in interface CommandsFactory

buildTxCompletionNotificationCommand

public org.infinispan.commands.remote.recovery.TxCompletionNotificationCommand buildTxCompletionNotificationCommand(XidImpl xid,
 GlobalTransaction globalTransaction)

Description copied from interface: CommandsFactory

Builds a TxCompletionNotificationCommand.

Specified by:

buildTxCompletionNotificationCommand in interface CommandsFactory

buildTxCompletionNotificationCommand

public org.infinispan.commands.remote.recovery.TxCompletionNotificationCommand buildTxCompletionNotificationCommand(long internalId)

Specified by:

buildTxCompletionNotificationCommand in interface CommandsFactory

Parameters:

internalId - the internal id identifying the transaction to be removed.

See Also:

• TxCompletionNotificationCommand

buildGetInDoubtTxInfoCommand

public org.infinispan.commands.remote.recovery.GetInDoubtTxInfoCommand buildGetInDoubtTxInfoCommand()

Specified by:

buildGetInDoubtTxInfoCommand in interface CommandsFactory

See Also:

• GetInDoubtTxInfoCommand

buildCompleteTransactionCommand

public org.infinispan.commands.remote.recovery.CompleteTransactionCommand buildCompleteTransactionCommand(XidImpl xid,
 boolean commit)

Description copied from interface: CommandsFactory

Builds a CompleteTransactionCommand command.

Specified by:

buildCompleteTransactionCommand in interface CommandsFactory

Parameters:

xid - the xid identifying the transaction we want to complete.

commit - commit(true) or rollback(false)?

buildXSiteStateTransferCancelSendCommand

public XSiteStateTransferCancelSendCommand buildXSiteStateTransferCancelSendCommand(String siteName)

Specified by:

buildXSiteStateTransferCancelSendCommand in interface CommandsFactory

buildXSiteStateTransferClearStatusCommand

public XSiteStateTransferClearStatusCommand buildXSiteStateTransferClearStatusCommand()

Specified by:

buildXSiteStateTransferClearStatusCommand in interface CommandsFactory

buildXSiteStateTransferFinishReceiveCommand

public XSiteStateTransferFinishReceiveCommand buildXSiteStateTransferFinishReceiveCommand(String siteName)

Specified by:

buildXSiteStateTransferFinishReceiveCommand in interface CommandsFactory

buildXSiteStateTransferFinishSendCommand

public XSiteStateTransferFinishSendCommand buildXSiteStateTransferFinishSendCommand(String siteName,
 boolean statusOk)

Specified by:

buildXSiteStateTransferFinishSendCommand in interface CommandsFactory

buildXSiteStateTransferRestartSendingCommand

public XSiteStateTransferRestartSendingCommand buildXSiteStateTransferRestartSendingCommand(String siteName,
 int topologyId)

Specified by:

buildXSiteStateTransferRestartSendingCommand in interface CommandsFactory

buildXSiteStateTransferStartReceiveCommand

public XSiteStateTransferStartReceiveCommand buildXSiteStateTransferStartReceiveCommand(String siteName)

Specified by:

buildXSiteStateTransferStartReceiveCommand in interface CommandsFactory

buildXSiteStateTransferStartSendCommand

public XSiteStateTransferStartSendCommand buildXSiteStateTransferStartSendCommand(String siteName,
 int topologyId)

Specified by:

buildXSiteStateTransferStartSendCommand in interface CommandsFactory

buildXSiteStateTransferStatusRequestCommand

public XSiteStateTransferStatusRequestCommand buildXSiteStateTransferStatusRequestCommand()

Specified by:

buildXSiteStateTransferStatusRequestCommand in interface CommandsFactory

buildXSiteStateTransferControlRequest

public XSiteStateTransferControlRequest buildXSiteStateTransferControlRequest(boolean startReceiving)

Specified by:

buildXSiteStateTransferControlRequest in interface CommandsFactory

buildXSiteAmendOfflineStatusCommand

public XSiteAmendOfflineStatusCommand buildXSiteAmendOfflineStatusCommand(String siteName,
 Integer afterFailures,
 Long minTimeToWait)

Specified by:

buildXSiteAmendOfflineStatusCommand in interface CommandsFactory

buildXSiteBringOnlineCommand

public XSiteBringOnlineCommand buildXSiteBringOnlineCommand(String siteName)

Specified by:

buildXSiteBringOnlineCommand in interface CommandsFactory

buildXSiteOfflineStatusCommand

public XSiteOfflineStatusCommand buildXSiteOfflineStatusCommand(String siteName)

Specified by:

buildXSiteOfflineStatusCommand in interface CommandsFactory

buildXSiteStatusCommand

public XSiteStatusCommand buildXSiteStatusCommand()

Specified by:

buildXSiteStatusCommand in interface CommandsFactory

buildXSiteTakeOfflineCommand

public XSiteTakeOfflineCommand buildXSiteTakeOfflineCommand(String siteName)

Specified by:

buildXSiteTakeOfflineCommand in interface CommandsFactory

buildXSiteStatePushCommand

public XSiteStatePushCommand buildXSiteStatePushCommand(XSiteState[] chunk)

Description copied from interface: CommandsFactory

Builds XSiteStatePushCommand used to transfer a single chunk of data between sites.

Specified by:

buildXSiteStatePushCommand in interface CommandsFactory

Parameters:

chunk - the data chunk

Returns:

the XSiteStatePushCommand created

buildSingleXSiteRpcCommand

public org.infinispan.xsite.SingleXSiteRpcCommand buildSingleXSiteRpcCommand(VisitableCommand command)

Description copied from interface: CommandsFactory

Builds SingleRpcCommand used to perform VisitableCommand on the backup site,

Specified by:

buildSingleXSiteRpcCommand in interface CommandsFactory

Parameters:

command - the visitable command.

Returns:

the SingleXSiteRpcCommand created

buildGetCacheEntryCommand

public org.infinispan.commands.read.GetCacheEntryCommand buildGetCacheEntryCommand(Object key,
 int segment,
 long flagsBitSet)

Description copied from interface: CommandsFactory

Builds a GetCacheEntryCommand

Specified by:

buildGetCacheEntryCommand in interface CommandsFactory

Parameters:

key - key to get

segment - the segment for the key

flagsBitSet - Command flags provided by cache

Returns:

a GetCacheEntryCommand

buildClusteredGetAllCommand

public org.infinispan.commands.remote.ClusteredGetAllCommand buildClusteredGetAllCommand(List<?> keys,
 long flagsBitSet,
 GlobalTransaction gtx)

Description copied from interface: CommandsFactory

Builds a ClusteredGetAllCommand, which is a remote lookup command

Specified by:

buildClusteredGetAllCommand in interface CommandsFactory

Parameters:

keys - key to look up

flagsBitSet - Command flags provided by cache

Returns:

a ClusteredGetAllCommand

buildReadOnlyKeyCommand

public <K,
V,
R>
org.infinispan.commands.functional.ReadOnlyKeyCommand<K,V,R> buildReadOnlyKeyCommand(Object key,
 Function<EntryView.ReadEntryView<K,V>,R> f,
 int segment,
 Params params,
 DataConversion keyDataConversion,
 DataConversion valueDataConversion)

Specified by:

buildReadOnlyKeyCommand in interface CommandsFactory

buildReadOnlyManyCommand

public <K,
V,
R>
org.infinispan.commands.functional.ReadOnlyManyCommand<K,V,R> buildReadOnlyManyCommand(Collection<?> keys,
 Function<EntryView.ReadEntryView<K,V>,R> f,
 Params params,
 DataConversion keyDataConversion,
 DataConversion valueDataConversion)

Specified by:

buildReadOnlyManyCommand in interface CommandsFactory

buildReadWriteKeyValueCommand

public <K,
V,
T,
R>
org.infinispan.commands.functional.ReadWriteKeyValueCommand<K,V,T,R> buildReadWriteKeyValueCommand(Object key,
 Object argument,
 BiFunction<T,EntryView.ReadWriteEntryView<K,V>,R> f,
 int segment,
 Params params,
 DataConversion keyDataConversion,
 DataConversion valueDataConversion)

Specified by:

buildReadWriteKeyValueCommand in interface CommandsFactory

buildReadWriteKeyCommand

public <K,
V,
R>
org.infinispan.commands.functional.ReadWriteKeyCommand<K,V,R> buildReadWriteKeyCommand(Object key,
 Function<EntryView.ReadWriteEntryView<K,V>,R> f,
 int segment,
 Params params,
 DataConversion keyDataConversion,
 DataConversion valueDataConversion)

Specified by:

buildReadWriteKeyCommand in interface CommandsFactory

buildReadWriteManyCommand

public <K,
V,
R>
org.infinispan.commands.functional.ReadWriteManyCommand<K,V,R> buildReadWriteManyCommand(Collection<?> keys,
 Function<EntryView.ReadWriteEntryView<K,V>,R> f,
 Params params,
 DataConversion keyDataConversion,
 DataConversion valueDataConversion)

Specified by:

buildReadWriteManyCommand in interface CommandsFactory

buildReadWriteManyEntriesCommand

public <K,
V,
T,
R>
org.infinispan.commands.functional.ReadWriteManyEntriesCommand<K,V,T,R> buildReadWriteManyEntriesCommand(Map<?,?> entries,
 BiFunction<T,EntryView.ReadWriteEntryView<K,V>,R> f,
 Params params,
 DataConversion keyDataConversion,
 DataConversion valueDataConversion)

Specified by:

buildReadWriteManyEntriesCommand in interface CommandsFactory

buildInvalidateVersionsCommand

public org.infinispan.commands.write.InvalidateVersionsCommand buildInvalidateVersionsCommand(int topologyId,
 Object[] keys,
 int[] topologyIds,
 long[] versions,
 boolean removed)

Specified by:

buildInvalidateVersionsCommand in interface CommandsFactory

buildWriteOnlyKeyCommand

public <K,
V>
org.infinispan.commands.functional.WriteOnlyKeyCommand<K,V> buildWriteOnlyKeyCommand(Object key,
 Consumer<EntryView.WriteEntryView<K,V>> f,
 int segment,
 Params params,
 DataConversion keyDataConversion,
 DataConversion valueDataConversion)

Specified by:

buildWriteOnlyKeyCommand in interface CommandsFactory

buildWriteOnlyKeyValueCommand

public <K,
V,
T>
org.infinispan.commands.functional.WriteOnlyKeyValueCommand<K,V,T> buildWriteOnlyKeyValueCommand(Object key,
 Object argument,
 BiConsumer<T,EntryView.WriteEntryView<K,V>> f,
 int segment,
 Params params,
 DataConversion keyDataConversion,
 DataConversion valueDataConversion)

Specified by:

buildWriteOnlyKeyValueCommand in interface CommandsFactory

buildWriteOnlyManyCommand

public <K,
V>
org.infinispan.commands.functional.WriteOnlyManyCommand<K,V> buildWriteOnlyManyCommand(Collection<?> keys,
 Consumer<EntryView.WriteEntryView<K,V>> f,
 Params params,
 DataConversion keyDataConversion,
 DataConversion valueDataConversion)

Specified by:

buildWriteOnlyManyCommand in interface CommandsFactory

buildWriteOnlyManyEntriesCommand

public <K,
V,
T>
org.infinispan.commands.functional.WriteOnlyManyEntriesCommand<K,V,T> buildWriteOnlyManyEntriesCommand(Map<?,?> arguments,
 BiConsumer<T,EntryView.WriteEntryView<K,V>> f,
 Params params,
 DataConversion keyDataConversion,
 DataConversion valueDataConversion)

Specified by:

buildWriteOnlyManyEntriesCommand in interface CommandsFactory

buildTxReadOnlyKeyCommand

public <K,
V,
R>
org.infinispan.commands.functional.TxReadOnlyKeyCommand<K,V,R> buildTxReadOnlyKeyCommand(Object key,
 Function<EntryView.ReadEntryView<K,V>,R> f,
 List<org.infinispan.commands.functional.Mutation<K,V,?>> mutations,
 int segment,
 Params params,
 DataConversion keyDataConversion,
 DataConversion valueDataConversion)

Specified by:

buildTxReadOnlyKeyCommand in interface CommandsFactory

buildTxReadOnlyManyCommand

public <K,
V,
R>
org.infinispan.commands.functional.TxReadOnlyManyCommand<K,V,R> buildTxReadOnlyManyCommand(Collection<?> keys,
 List<List<org.infinispan.commands.functional.Mutation<K,V,?>>> mutations,
 Params params,
 DataConversion keyDataConversion,
 DataConversion valueDataConversion)

Specified by:

buildTxReadOnlyManyCommand in interface CommandsFactory

buildBackupAckCommand

public org.infinispan.commands.write.BackupAckCommand buildBackupAckCommand(long id,
 int topologyId)

Specified by:

buildBackupAckCommand in interface CommandsFactory

buildBackupMultiKeyAckCommand

public org.infinispan.commands.write.BackupMultiKeyAckCommand buildBackupMultiKeyAckCommand(long id,
 int segment,
 int topologyId)

Specified by:

buildBackupMultiKeyAckCommand in interface CommandsFactory

buildExceptionAckCommand

public org.infinispan.commands.write.ExceptionAckCommand buildExceptionAckCommand(long id,
 Throwable throwable,
 int topologyId)

Specified by:

buildExceptionAckCommand in interface CommandsFactory

buildRevokeBiasCommand

public org.infinispan.commands.remote.RevokeBiasCommand buildRevokeBiasCommand(Address ackTarget,
 long id,
 int topologyId,
 Collection<Object> keys)

Specified by:

buildRevokeBiasCommand in interface CommandsFactory

buildRenewBiasCommand

public org.infinispan.commands.remote.RenewBiasCommand buildRenewBiasCommand(Object[] keys)

Specified by:

buildRenewBiasCommand in interface CommandsFactory

buildSingleKeyBackupWriteCommand

public org.infinispan.commands.triangle.SingleKeyBackupWriteCommand buildSingleKeyBackupWriteCommand()

Specified by:

buildSingleKeyBackupWriteCommand in interface CommandsFactory

buildSingleKeyFunctionalBackupWriteCommand

public org.infinispan.commands.triangle.SingleKeyFunctionalBackupWriteCommand buildSingleKeyFunctionalBackupWriteCommand()

Specified by:

buildSingleKeyFunctionalBackupWriteCommand in interface CommandsFactory

buildPutMapBackupWriteCommand

public org.infinispan.commands.triangle.PutMapBackupWriteCommand buildPutMapBackupWriteCommand()

Specified by:

buildPutMapBackupWriteCommand in interface CommandsFactory

buildMultiEntriesFunctionalBackupWriteCommand

public org.infinispan.commands.triangle.MultiEntriesFunctionalBackupWriteCommand buildMultiEntriesFunctionalBackupWriteCommand()

Specified by:

buildMultiEntriesFunctionalBackupWriteCommand in interface CommandsFactory

buildMultiKeyFunctionalBackupWriteCommand

public org.infinispan.commands.triangle.MultiKeyFunctionalBackupWriteCommand buildMultiKeyFunctionalBackupWriteCommand()

Specified by:

buildMultiKeyFunctionalBackupWriteCommand in interface CommandsFactory

buildBackupNoopCommand

public org.infinispan.commands.triangle.BackupNoopCommand buildBackupNoopCommand()

Specified by:

buildBackupNoopCommand in interface CommandsFactory

buildKeyReductionPublisherCommand

public <K,
R>
org.infinispan.reactive.publisher.impl.commands.reduction.ReductionPublisherRequestCommand<K> buildKeyReductionPublisherCommand(boolean parallelStream,
 DeliveryGuarantee deliveryGuarantee,
 IntSet segments,
 Set<K> keys,
 Set<K> excludedKeys,
 long explicitFlags,
 Function<? super org.reactivestreams.Publisher<K>,? extends CompletionStage<R>> transformer,
 Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)

Specified by:

buildKeyReductionPublisherCommand in interface CommandsFactory

buildEntryReductionPublisherCommand

public <K,
V,
R>
org.infinispan.reactive.publisher.impl.commands.reduction.ReductionPublisherRequestCommand<K> buildEntryReductionPublisherCommand(boolean parallelStream,
 DeliveryGuarantee deliveryGuarantee,
 IntSet segments,
 Set<K> keys,
 Set<K> excludedKeys,
 long explicitFlags,
 Function<? super org.reactivestreams.Publisher<CacheEntry<K,V>>,? extends CompletionStage<R>> transformer,
 Function<? super org.reactivestreams.Publisher<R>,? extends CompletionStage<R>> finalizer)

Specified by:

buildEntryReductionPublisherCommand in interface CommandsFactory

buildInitialPublisherCommand

public <K,
I,
R>
org.infinispan.reactive.publisher.impl.commands.batch.InitialPublisherCommand<K,I,R> buildInitialPublisherCommand(String requestId,
 DeliveryGuarantee deliveryGuarantee,
 int batchSize,
 IntSet segments,
 Set<K> keys,
 Set<K> excludedKeys,
 long explicitFlags,
 boolean entryStream,
 boolean trackKeys,
 Function<? super org.reactivestreams.Publisher<I>,? extends org.reactivestreams.Publisher<R>> transformer)

Specified by:

buildInitialPublisherCommand in interface CommandsFactory

buildNextPublisherCommand

public org.infinispan.reactive.publisher.impl.commands.batch.NextPublisherCommand buildNextPublisherCommand(String requestId)

Specified by:

buildNextPublisherCommand in interface CommandsFactory

buildCancelPublisherCommand

public org.infinispan.reactive.publisher.impl.commands.batch.CancelPublisherCommand buildCancelPublisherCommand(String requestId)

Specified by:

buildCancelPublisherCommand in interface CommandsFactory

buildMultiClusterEventCommand

public <K,
V> MultiClusterEventCommand<K,V> buildMultiClusterEventCommand(Map<UUID,Collection<ClusterEvent<K,V>>> events)

Specified by:

buildMultiClusterEventCommand in interface CommandsFactory

buildCheckTransactionRpcCommand

public org.infinispan.commands.remote.CheckTransactionRpcCommand buildCheckTransactionRpcCommand(Collection<GlobalTransaction> globalTransactions)

Specified by:

buildCheckTransactionRpcCommand in interface CommandsFactory

buildTouchCommand

public TouchCommand buildTouchCommand(Object key,
 int segment,
 boolean touchEvenIfExpired,
 long flagBitSet)

Specified by:

buildTouchCommand in interface CommandsFactory

buildIracClearKeysCommand

public IracClearKeysRequest buildIracClearKeysCommand()

Specified by:

buildIracClearKeysCommand in interface CommandsFactory

buildIracCleanupKeyCommand

public org.infinispan.commands.irac.IracCleanupKeysCommand buildIracCleanupKeyCommand(Collection<? extends IracManagerKeyInfo> state)

Specified by:

buildIracCleanupKeyCommand in interface CommandsFactory

buildIracTombstoneCleanupCommand

public org.infinispan.commands.irac.IracTombstoneCleanupCommand buildIracTombstoneCleanupCommand(int maxCapacity)

Specified by:

buildIracTombstoneCleanupCommand in interface CommandsFactory

buildIracMetadataRequestCommand

public org.infinispan.commands.irac.IracMetadataRequestCommand buildIracMetadataRequestCommand(int segment,
 IracEntryVersion versionSeen)

Specified by:

buildIracMetadataRequestCommand in interface CommandsFactory

buildIracRequestStateCommand

public org.infinispan.commands.irac.IracRequestStateCommand buildIracRequestStateCommand(IntSet segments)

Specified by:

buildIracRequestStateCommand in interface CommandsFactory

buildIracStateResponseCommand

public org.infinispan.commands.irac.IracStateResponseCommand buildIracStateResponseCommand(int capacity)

Specified by:

buildIracStateResponseCommand in interface CommandsFactory

buildIracPutKeyValueCommand

public org.infinispan.commands.write.IracPutKeyValueCommand buildIracPutKeyValueCommand(Object key,
 int segment,
 Object value,
 Metadata metadata,
 PrivateMetadata privateMetadata)

Specified by:

buildIracPutKeyValueCommand in interface CommandsFactory

buildIracTouchCommand

public IracTouchKeyRequest buildIracTouchCommand(Object key)

Specified by:

buildIracTouchCommand in interface CommandsFactory

buildIracUpdateVersionCommand

public org.infinispan.commands.irac.IracUpdateVersionCommand buildIracUpdateVersionCommand(Map<Integer,IracEntryVersion> segmentsVersion)

Specified by:

buildIracUpdateVersionCommand in interface CommandsFactory

buildXSiteAutoTransferStatusCommand

public XSiteAutoTransferStatusCommand buildXSiteAutoTransferStatusCommand(String site)

Specified by:

buildXSiteAutoTransferStatusCommand in interface CommandsFactory

buildXSiteSetStateTransferModeCommand

public XSiteSetStateTransferModeCommand buildXSiteSetStateTransferModeCommand(String site,
 XSiteStateTransferMode mode)

Specified by:

buildXSiteSetStateTransferModeCommand in interface CommandsFactory

buildIracTombstoneRemoteSiteCheckCommand

public org.infinispan.commands.irac.IracTombstoneRemoteSiteCheckCommand buildIracTombstoneRemoteSiteCheckCommand(List<Object> keys)

Specified by:

buildIracTombstoneRemoteSiteCheckCommand in interface CommandsFactory

buildIracTombstoneStateResponseCommand

public org.infinispan.commands.irac.IracTombstoneStateResponseCommand buildIracTombstoneStateResponseCommand(Collection<IracTombstoneInfo> state)

Specified by:

buildIracTombstoneStateResponseCommand in interface CommandsFactory

buildIracTombstonePrimaryCheckCommand

public org.infinispan.commands.irac.IracTombstonePrimaryCheckCommand buildIracTombstonePrimaryCheckCommand(Collection<IracTombstoneInfo> tombstones)

Specified by:

buildIracTombstonePrimaryCheckCommand in interface CommandsFactory

buildIracPutManyCommand

public IracPutManyRequest buildIracPutManyCommand(int capacity)

Specified by:

buildIracPutManyCommand in interface CommandsFactory

buildXSiteStatePushRequest

public XSiteStatePushRequest buildXSiteStatePushRequest(XSiteState[] chunk,
 long timeoutMillis)

Specified by:

buildXSiteStatePushRequest in interface CommandsFactory

buildIracTombstoneCheckRequest

public IracTombstoneCheckRequest buildIracTombstoneCheckRequest(List<Object> keys)

Specified by:

buildIracTombstoneCheckRequest in interface CommandsFactory