Interface CommandsFactory

All Known Implementing Classes:

CommandsFactoryImpl

public interface CommandsFactory

A factory to build commands, initializing and injecting dependencies accordingly. Commands built for a specific, named cache instance cannot be reused on a different cache instance since most commands contain the cache name it was built for along with references to other named-cache scoped components.

Since:

4.0

Author:

Manik Surtani, Mircea.Markus@jboss.com, Galder Zamarreño

Method Summary

Modifier and Type	Method	Description
BackupMultiKeyAckCommand	buildBackupMultiKeyAckCommand(long id, int segment, int topologyId)
BackupNoopCommand	buildBackupNoopCommand(WriteCommand command, long sequence, int segmentId)
org.infinispan.reactive.publisher.impl.commands.batch.CancelPublisherCommand	buildCancelPublisherCommand(String requestId)
CheckTransactionRpcCommand	buildCheckTransactionRpcCommand(Collection<GlobalTransaction> globalTransactions)
ClearCommand	buildClearCommand(long flagsBitSet)	Builds a ClearCommand
ClusteredGetAllCommand	buildClusteredGetAllCommand(List<?> keys, long flagsBitSet, GlobalTransaction gtx)	Builds a ClusteredGetAllCommand, which is a remote lookup command
ClusteredGetCommand	buildClusteredGetCommand(Object key, Integer segment, long flagsBitSet)	Builds a ClusteredGetCommand, which is a remote lookup command
CommitCommand	buildCommitCommand(GlobalTransaction gtx)	Builds a CommitCommand
CompleteTransactionCommand	buildCompleteTransactionCommand(org.infinispan.commons.tx.XidImpl xid, boolean commit)	Builds a CompleteTransactionCommand command.
ComputeCommand	buildComputeCommand(Object key, BiFunction mappingFunction, boolean computeIfPresent, int segment, Metadata metadata, long flagsBitSet)	Builds a ComputeCommand
ComputeIfAbsentCommand	buildComputeIfAbsentCommand(Object key, Function mappingFunction, int segment, Metadata metadata, long flagsBitSet)	Builds a ComputeIfAbsentCommand
ConflictResolutionStartCommand	buildConflictResolutionStartCommand(int topologyId, org.infinispan.commons.util.IntSet segments)
<K,V,R> org.infinispan.reactive.publisher.impl.commands.reduction.ReductionPublisherRequestCommand<K>	buildEntryReductionPublisherCommand(boolean parallelStream, DeliveryGuarantee deliveryGuarantee, org.infinispan.commons.util.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)
EntrySetCommand	buildEntrySetCommand(long flagsBitSet)	Builds a EntrySetCommand
EvictCommand	buildEvictCommand(Object key, int segment, long flagsBitSet)	Builds an EvictCommand
ExceptionAckCommand	buildExceptionAckCommand(long id, Throwable throwable, int topologyId)
GetAllCommand	buildGetAllCommand(Collection<?> keys, long flagsBitSet, boolean returnEntries)	Builds a GetAllCommand
GetCacheEntryCommand	buildGetCacheEntryCommand(Object key, int segment, long flagsBitSet)	Builds a GetCacheEntryCommand
GetInDoubtTransactionsCommand	buildGetInDoubtTransactionsCommand()	Builds a GetInDoubtTransactionsCommand.
GetInDoubtTxInfoCommand	buildGetInDoubtTxInfoCommand()
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, org.infinispan.commons.util.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)
InvalidateCommand	buildInvalidateCommand(long flagsBitSet, Object... keys)	Builds an InvalidateCommand
InvalidateCommand	buildInvalidateFromL1Command(long flagsBitSet, Collection<Object> keys)	Builds an InvalidateFromL1Command
InvalidateCommand	buildInvalidateFromL1Command(Address origin, long flagsBitSet, Collection<Object> keys)
IracCleanupKeysCommand	buildIracCleanupKeyCommand(Collection<IracManagerKeyInfo> state)
IracClearKeysRequest	buildIracClearKeysCommand()
IracMetadataRequestCommand	buildIracMetadataRequestCommand(int segment, IracEntryVersion versionSeen)
IracPrimaryPendingKeyCheckCommand	buildIracPrimaryPendingKeyCheckCommand(List<IracManagerKeyInfo> keys)
IracPutKeyValueCommand	buildIracPutKeyValueCommand(Object key, int segment, Object value, Metadata metadata, PrivateMetadata privateMetadata)
IracPutManyRequest	buildIracPutManyCommand(int capacity)
IracRequestStateCommand	buildIracRequestStateCommand(org.infinispan.commons.util.IntSet segments)
IracStateResponseCommand	buildIracStateResponseCommand(int capacity)
IracTombstoneCheckRequest	buildIracTombstoneCheckRequest(List<Object> keys)
IracTombstoneCleanupCommand	buildIracTombstoneCleanupCommand(int maxCapacity)
IracTombstonePrimaryCheckCommand	buildIracTombstonePrimaryCheckCommand(Collection<IracTombstoneInfo> tombstones)
IracTombstoneRemoteSiteCheckCommand	buildIracTombstoneRemoteSiteCheckCommand(List<Object> keys)
IracTombstoneStateResponseCommand	buildIracTombstoneStateResponseCommand(Collection<IracTombstoneInfo> state)
IracTouchKeyRequest	buildIracTouchCommand(Object key)
IracUpdateVersionCommand	buildIracUpdateVersionCommand(Map<Integer, IracEntryVersion> segmentsVersion)
<K,R> org.infinispan.reactive.publisher.impl.commands.reduction.ReductionPublisherRequestCommand<K>	buildKeyReductionPublisherCommand(boolean parallelStream, DeliveryGuarantee deliveryGuarantee, org.infinispan.commons.util.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)
KeySetCommand	buildKeySetCommand(long flagsBitSet)	Builds a KeySetCommand
LockControlCommand	buildLockControlCommand(Object key, long flagsBitSet, GlobalTransaction gtx)	Same as buildLockControlCommand(Collection, long, GlobalTransaction) but for locking a single key vs a collection of keys.
LockControlCommand	buildLockControlCommand(Collection<?> keys, long flagsBitSet)
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)
<K,V,T,R> MultiEntriesFunctionalBackupWriteCommand	buildMultiEntriesFunctionalBackupWriteCommand(ReadWriteManyEntriesCommand<K,V,T,R> command, Collection<Object> keys, long sequence, int segmentId)
<K,V,T> MultiEntriesFunctionalBackupWriteCommand	buildMultiEntriesFunctionalBackupWriteCommand(WriteOnlyManyEntriesCommand<K,V,T> command, Collection<Object> keys, long sequence, int segmentId)
<K,V,R> MultiKeyFunctionalBackupWriteCommand	buildMultiKeyFunctionalBackupWriteCommand(ReadWriteManyCommand<K,V,R> command, Collection<Object> keys, long sequence, int segmentId)
<K,V> MultiKeyFunctionalBackupWriteCommand	buildMultiKeyFunctionalBackupWriteCommand(WriteOnlyManyCommand<K,V> command, Collection<Object> keys, long sequence, int segmentId)
org.infinispan.reactive.publisher.impl.commands.batch.NextPublisherCommand	buildNextPublisherCommand(String requestId)
PrepareCommand	buildPrepareCommand(GlobalTransaction gtx, List<WriteCommand> modifications, boolean onePhaseCommit)	Builds a PrepareCommand
default PutKeyValueCommand	buildPutKeyValueCommand(Object key, Object value, int segment, Metadata metadata, long flagsBitSet)	Builds a PutKeyValueCommand
PutKeyValueCommand	buildPutKeyValueCommand(Object key, Object value, int segment, Metadata metadata, long flagsBitSet, boolean returnEntry)
PutMapBackupWriteCommand	buildPutMapBackupWriteCommand(PutMapCommand command, Collection<Object> keys, long sequence, int segmentId)
PutMapCommand	buildPutMapCommand(Map<?,?> map, Metadata metadata, long flagsBitSet)	Builds a PutMapCommand
<K,V,R> 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> ReadOnlyManyCommand<K,V,R>	buildReadOnlyManyCommand(Collection<?> keys, Function<EntryView.ReadEntryView<K,V>, R> f, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)
<K,V,R> 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> 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> ReadWriteManyCommand<K,V,R>	buildReadWriteManyCommand(Collection<?> keys, Function<EntryView.ReadWriteEntryView<K,V>, R> f, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)
<K,V,T,R> ReadWriteManyEntriesCommand<K,V,T,R>	buildReadWriteManyEntriesCommand(Map<?,?> entries, BiFunction<T, EntryView.ReadWriteEntryView<K,V>, R> f, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)
default RemoveCommand	buildRemoveCommand(Object key, Object value, int segment, long flagsBitSet)	Builds a RemoveCommand
RemoveCommand	buildRemoveCommand(Object key, Object value, int segment, long flagsBitSet, boolean returnEntry)
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
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
default ReplaceCommand	buildReplaceCommand(Object key, Object oldValue, Object newValue, int segment, Metadata metadata, long flagsBitSet)	Builds a ReplaceCommand
ReplaceCommand	buildReplaceCommand(Object key, Object oldValue, Object newValue, int segment, Metadata metadata, long flagsBitSet, boolean returnEntry)	Builds a ReplaceCommand
RollbackCommand	buildRollbackCommand(GlobalTransaction gtx)	Builds a RollbackCommand
<K,V,R> SingleKeyFunctionalBackupWriteCommand	buildSingleKeyBackupWriteCommand(ReadWriteKeyCommand<K,V,R> command, long sequence, int segmentId)
<K,V,T,R> SingleKeyFunctionalBackupWriteCommand	buildSingleKeyBackupWriteCommand(ReadWriteKeyValueCommand<K,V,T,R> command, long sequence, int segmentId)
<K,V> SingleKeyFunctionalBackupWriteCommand	buildSingleKeyBackupWriteCommand(WriteOnlyKeyCommand<K,V> command, long sequence, int segmentId)
<K,V,T> SingleKeyFunctionalBackupWriteCommand	buildSingleKeyBackupWriteCommand(WriteOnlyKeyValueCommand<K,V,T> command, long sequence, int segmentId)
SingleKeyBackupWriteCommand	buildSingleKeyBackupWriteCommand(ComputeCommand command, long sequence, int segmentId)
SingleKeyBackupWriteCommand	buildSingleKeyBackupWriteCommand(ComputeIfAbsentCommand command, long sequence, int segmentId)
SingleKeyBackupWriteCommand	buildSingleKeyBackupWriteCommand(IracPutKeyValueCommand command, long sequence, int segmentId)
SingleKeyBackupWriteCommand	buildSingleKeyBackupWriteCommand(PutKeyValueCommand command, long sequence, int segmentId)
SingleKeyBackupWriteCommand	buildSingleKeyBackupWriteCommand(RemoveCommand command, long sequence, int segmentId)
SingleKeyBackupWriteCommand	buildSingleKeyBackupWriteCommand(ReplaceCommand command, long sequence, int segmentId)
SingleXSiteRpcCommand	buildSingleXSiteRpcCommand(VisitableCommand command)	Builds SingleRpcCommand used to perform VisitableCommand on the backup site,
SizeCommand	buildSizeCommand(org.infinispan.commons.util.IntSet segments, long flagsBitSet)	Builds a SizeCommand
StateResponseCommand	buildStateResponseCommand(int viewId, Collection<StateChunk> stateChunks, boolean applyState)	Builds a StateResponseCommand used for pushing cache entries to another node.
StateTransferCancelCommand	buildStateTransferCancelCommand(int topologyId, org.infinispan.commons.util.IntSet segments)
StateTransferGetListenersCommand	buildStateTransferGetListenersCommand(int topologyId)
StateTransferGetTransactionsCommand	buildStateTransferGetTransactionsCommand(int topologyId, org.infinispan.commons.util.IntSet segments)
StateTransferStartCommand	buildStateTransferStartCommand(int topologyId, org.infinispan.commons.util.IntSet segments)
TouchCommand	buildTouchCommand(Object key, int segment, boolean touchEvenIfExpired, long flagBitSet)
TxCompletionNotificationCommand	buildTxCompletionNotificationCommand(long internalId)
TxCompletionNotificationCommand	buildTxCompletionNotificationCommand(org.infinispan.commons.tx.XidImpl xid, GlobalTransaction globalTransaction)	Builds a TxCompletionNotificationCommand.
<K,V,R> TxReadOnlyKeyCommand<K,V,R>	buildTxReadOnlyKeyCommand(Object key, Function<EntryView.ReadEntryView<K,V>, R> f, List<Mutation<K,V,?>> mutations, int segment, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)
<K,V,R> TxReadOnlyManyCommand<K,V,R>	buildTxReadOnlyManyCommand(Collection<?> keys, List<List<Mutation<K,V,?>>> mutations, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)
VersionedCommitCommand	buildVersionedCommitCommand(GlobalTransaction gtx)	Builds a VersionedCommitCommand
VersionedPrepareCommand	buildVersionedPrepareCommand(GlobalTransaction gtx, List<WriteCommand> modifications, boolean onePhase)	Builds a VersionedPrepareCommand
<K,V> WriteOnlyKeyCommand<K,V>	buildWriteOnlyKeyCommand(Object key, Consumer<EntryView.WriteEntryView<K,V>> f, int segment, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)
<K,V,T> 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> WriteOnlyManyCommand<K,V>	buildWriteOnlyManyCommand(Collection<?> keys, Consumer<EntryView.WriteEntryView<K,V>> f, Params params, DataConversion keyDataConversion, DataConversion valueDataConversion)
<K,V,T> 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)
XSiteSetStateTransferModeCommand	buildXSiteSetStateTransferModeCommand(String site, XSiteStateTransferMode mode)
XSiteStatePushCommand	buildXSiteStatePushCommand(List<XSiteState> chunk)	Builds XSiteStatePushCommand used to transfer a single chunk of data between sites.
default XSiteStatePushCommand	buildXSiteStatePushCommand(XSiteState[] chunk)	Deprecated, for removal: This API element is subject to removal in a future version. since 16.0, use buildXSiteStatePushCommand(List) instead
XSiteStatePushRequest	buildXSiteStatePushRequest(List<XSiteState> chunk, long timeoutMillis)
default XSiteStatePushRequest	buildXSiteStatePushRequest(XSiteState[] chunk, long timeoutMillis)	Deprecated, for removal: This API element is subject to removal in a future version. since 16.0, use buildXSiteStatePushRequest(List, long) instead
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()
String	getCacheName()	Retrieves the cache name this CommandFactory is set up to construct commands for.

Method Details

buildPutKeyValueCommand

default PutKeyValueCommand buildPutKeyValueCommand(Object key,
 Object value,
 int segment,
 Metadata metadata,
 long flagsBitSet)

Builds a PutKeyValueCommand

Parameters:

key - key to put

value - value to put

segment - the segment of the given key

metadata - metadata of entry

flagsBitSet - Command flags provided by cache

Returns:

a PutKeyValueCommand

buildPutKeyValueCommand

PutKeyValueCommand buildPutKeyValueCommand(Object key,
 Object value,
 int segment,
 Metadata metadata,
 long flagsBitSet,
 boolean returnEntry)

buildRemoveCommand

default RemoveCommand buildRemoveCommand(Object key,
 Object value,
 int segment,
 long flagsBitSet)

Builds a RemoveCommand

Parameters:

key - key to remove

value - value to check for ina conditional remove, or null for an unconditional remove.

segment - the segment of the given key

flagsBitSet - Command flags provided by cache

Returns:

a RemoveCommand

buildRemoveCommand

RemoveCommand buildRemoveCommand(Object key,
 Object value,
 int segment,
 long flagsBitSet,
 boolean returnEntry)

buildInvalidateCommand

InvalidateCommand buildInvalidateCommand(long flagsBitSet,
 Object... keys)

Builds an InvalidateCommand

Parameters:

flagsBitSet - Command flags provided by cache

keys - keys to invalidate

Returns:

an InvalidateCommand

buildInvalidateFromL1Command

InvalidateCommand buildInvalidateFromL1Command(long flagsBitSet,
 Collection<Object> keys)

Builds an InvalidateFromL1Command

Parameters:

flagsBitSet - Command flags provided by cache

keys - keys to invalidate

Returns:

an InvalidateFromL1Command

buildInvalidateFromL1Command

InvalidateCommand buildInvalidateFromL1Command(Address origin,
 long flagsBitSet,
 Collection<Object> keys)

See Also:

• buildInvalidateFromL1Command(long, Collection)

buildRemoveExpiredCommand

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

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

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

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

default ReplaceCommand buildReplaceCommand(Object key,
 Object oldValue,
 Object newValue,
 int segment,
 Metadata metadata,
 long flagsBitSet)

Builds a ReplaceCommand

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

Returns:

a ReplaceCommand

buildReplaceCommand

ReplaceCommand buildReplaceCommand(Object key,
 Object oldValue,
 Object newValue,
 int segment,
 Metadata metadata,
 long flagsBitSet,
 boolean returnEntry)

Builds a ReplaceCommand

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

ComputeCommand buildComputeCommand(Object key,
 BiFunction mappingFunction,
 boolean computeIfPresent,
 int segment,
 Metadata metadata,
 long flagsBitSet)

Builds a ComputeCommand

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

ComputeIfAbsentCommand buildComputeIfAbsentCommand(Object key,
 Function mappingFunction,
 int segment,
 Metadata metadata,
 long flagsBitSet)

Builds a ComputeIfAbsentCommand

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

SizeCommand buildSizeCommand(org.infinispan.commons.util.IntSet segments,
 long flagsBitSet)

Builds a SizeCommand

Parameters:

flagsBitSet - Command flags provided by cache

Returns:

a SizeCommand

buildGetKeyValueCommand

GetKeyValueCommand buildGetKeyValueCommand(Object key,
 int segment,
 long flagsBitSet)

Builds a GetKeyValueCommand

Parameters:

key - key to get

segment - the segment of the given key

flagsBitSet - Command flags provided by cache

Returns:

a GetKeyValueCommand

buildGetCacheEntryCommand

GetCacheEntryCommand buildGetCacheEntryCommand(Object key,
 int segment,
 long flagsBitSet)

Builds a GetCacheEntryCommand

Parameters:

key - key to get

segment - the segment for the key

flagsBitSet - Command flags provided by cache

Returns:

a GetCacheEntryCommand

buildGetAllCommand

GetAllCommand buildGetAllCommand(Collection<?> keys,
 long flagsBitSet,
 boolean returnEntries)

Builds a GetAllCommand

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

buildKeySetCommand

KeySetCommand buildKeySetCommand(long flagsBitSet)

Builds a KeySetCommand

Parameters:

flagsBitSet - Command flags provided by cache

Returns:

a KeySetCommand

buildEntrySetCommand

EntrySetCommand buildEntrySetCommand(long flagsBitSet)

Builds a EntrySetCommand

Parameters:

flagsBitSet - Command flags provided by cache

Returns:

a EntrySetCommand

buildPutMapCommand

PutMapCommand buildPutMapCommand(Map<?,?> map,
 Metadata metadata,
 long flagsBitSet)

Builds a PutMapCommand

Parameters:

map - map containing key/value entries to put

metadata - metadata of entry

flagsBitSet - Command flags provided by cache

Returns:

a PutMapCommand

buildClearCommand

ClearCommand buildClearCommand(long flagsBitSet)

Builds a ClearCommand

Parameters:

flagsBitSet - Command flags provided by cache

Returns:

a ClearCommand

buildEvictCommand

EvictCommand buildEvictCommand(Object key,
 int segment,
 long flagsBitSet)

Builds an EvictCommand

Parameters:

key - key to evict

segment - the segment for the key

flagsBitSet - Command flags provided by cache

Returns:

an EvictCommand

buildPrepareCommand

PrepareCommand buildPrepareCommand(GlobalTransaction gtx,
 List<WriteCommand> modifications,
 boolean onePhaseCommit)

Builds a PrepareCommand

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

VersionedPrepareCommand buildVersionedPrepareCommand(GlobalTransaction gtx,
 List<WriteCommand> modifications,
 boolean onePhase)

Builds a VersionedPrepareCommand

Parameters:

gtx - global transaction associated with the prepare

modifications - list of modifications

onePhase -

Returns:

a VersionedPrepareCommand

buildCommitCommand

CommitCommand buildCommitCommand(GlobalTransaction gtx)

Builds a CommitCommand

Parameters:

gtx - global transaction associated with the commit

Returns:

a CommitCommand

buildVersionedCommitCommand

VersionedCommitCommand buildVersionedCommitCommand(GlobalTransaction gtx)

Builds a VersionedCommitCommand

Parameters:

gtx - global transaction associated with the commit

Returns:

a VersionedCommitCommand

buildRollbackCommand

RollbackCommand buildRollbackCommand(GlobalTransaction gtx)

Builds a RollbackCommand

Parameters:

gtx - global transaction associated with the rollback

Returns:

a RollbackCommand

buildClusteredGetCommand

ClusteredGetCommand buildClusteredGetCommand(Object key,
 Integer segment,
 long flagsBitSet)

Builds a ClusteredGetCommand, which is a remote lookup command

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

buildClusteredGetAllCommand

ClusteredGetAllCommand buildClusteredGetAllCommand(List<?> keys,
 long flagsBitSet,
 GlobalTransaction gtx)

Builds a ClusteredGetAllCommand, which is a remote lookup command

Parameters:

keys - key to look up

flagsBitSet - Command flags provided by cache

Returns:

a ClusteredGetAllCommand

buildLockControlCommand

LockControlCommand buildLockControlCommand(Collection<?> keys,
 long flagsBitSet,
 GlobalTransaction gtx)

Builds a LockControlCommand to control explicit remote locking

Parameters:

keys - keys to lock

flagsBitSet - Command flags provided by cache

gtx -

Returns:

a LockControlCommand

buildLockControlCommand

LockControlCommand buildLockControlCommand(Object key,
 long flagsBitSet,
 GlobalTransaction gtx)

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

buildLockControlCommand

LockControlCommand buildLockControlCommand(Collection<?> keys,
 long flagsBitSet)

buildConflictResolutionStartCommand

ConflictResolutionStartCommand buildConflictResolutionStartCommand(int topologyId,
 org.infinispan.commons.util.IntSet segments)

buildStateTransferCancelCommand

StateTransferCancelCommand buildStateTransferCancelCommand(int topologyId,
 org.infinispan.commons.util.IntSet segments)

buildStateTransferGetListenersCommand

StateTransferGetListenersCommand buildStateTransferGetListenersCommand(int topologyId)

buildStateTransferGetTransactionsCommand

StateTransferGetTransactionsCommand buildStateTransferGetTransactionsCommand(int topologyId,
 org.infinispan.commons.util.IntSet segments)

buildStateTransferStartCommand

StateTransferStartCommand buildStateTransferStartCommand(int topologyId,
 org.infinispan.commons.util.IntSet segments)

buildStateResponseCommand

StateResponseCommand buildStateResponseCommand(int viewId,
 Collection<StateChunk> stateChunks,
 boolean applyState)

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

getCacheName

String getCacheName()

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

Returns:

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

buildGetInDoubtTransactionsCommand

GetInDoubtTransactionsCommand buildGetInDoubtTransactionsCommand()

Builds a GetInDoubtTransactionsCommand.

buildTxCompletionNotificationCommand

TxCompletionNotificationCommand buildTxCompletionNotificationCommand(org.infinispan.commons.tx.XidImpl xid,
 GlobalTransaction globalTransaction)

Builds a TxCompletionNotificationCommand.

buildGetInDoubtTxInfoCommand

GetInDoubtTxInfoCommand buildGetInDoubtTxInfoCommand()

See Also:

• GetInDoubtTxInfoCommand

buildCompleteTransactionCommand

CompleteTransactionCommand buildCompleteTransactionCommand(org.infinispan.commons.tx.XidImpl xid,
 boolean commit)

Builds a CompleteTransactionCommand command.

Parameters:

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

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

buildTxCompletionNotificationCommand

TxCompletionNotificationCommand buildTxCompletionNotificationCommand(long internalId)

Parameters:

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

See Also:

• TxCompletionNotificationCommand

buildXSiteStateTransferCancelSendCommand

XSiteStateTransferCancelSendCommand buildXSiteStateTransferCancelSendCommand(String siteName)

buildXSiteStateTransferClearStatusCommand

XSiteStateTransferClearStatusCommand buildXSiteStateTransferClearStatusCommand()

buildXSiteStateTransferFinishReceiveCommand

XSiteStateTransferFinishReceiveCommand buildXSiteStateTransferFinishReceiveCommand(String siteName)

buildXSiteStateTransferFinishSendCommand

XSiteStateTransferFinishSendCommand buildXSiteStateTransferFinishSendCommand(String siteName,
 boolean statusOk)

buildXSiteStateTransferRestartSendingCommand

XSiteStateTransferRestartSendingCommand buildXSiteStateTransferRestartSendingCommand(String siteName,
 int topologyId)

buildXSiteStateTransferStartReceiveCommand

XSiteStateTransferStartReceiveCommand buildXSiteStateTransferStartReceiveCommand(String siteName)

buildXSiteStateTransferStartSendCommand

XSiteStateTransferStartSendCommand buildXSiteStateTransferStartSendCommand(String siteName,
 int topologyId)

buildXSiteStateTransferStatusRequestCommand

XSiteStateTransferStatusRequestCommand buildXSiteStateTransferStatusRequestCommand()

buildXSiteStateTransferControlRequest

XSiteStateTransferControlRequest buildXSiteStateTransferControlRequest(boolean startReceiving)

buildXSiteAmendOfflineStatusCommand

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

buildXSiteStatePushCommand

@Deprecated(since="16.0",
            forRemoval=true)
default XSiteStatePushCommand buildXSiteStatePushCommand(XSiteState[] chunk)

Deprecated, for removal: This API element is subject to removal in a future version.

since 16.0, use buildXSiteStatePushCommand(List) instead

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

Parameters:

chunk - the data chunk

Returns:

the XSiteStatePushCommand created

buildXSiteStatePushCommand

XSiteStatePushCommand buildXSiteStatePushCommand(List<XSiteState> chunk)

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

Parameters:

chunk - the data chunk

Returns:

the XSiteStatePushCommand created

buildSingleXSiteRpcCommand

SingleXSiteRpcCommand buildSingleXSiteRpcCommand(VisitableCommand command)

Builds SingleRpcCommand used to perform VisitableCommand on the backup site,

Parameters:

command - the visitable command.

Returns:

the SingleXSiteRpcCommand created

buildReadOnlyKeyCommand

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

buildReadOnlyManyCommand

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

buildWriteOnlyKeyCommand

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

buildReadWriteKeyValueCommand

<K,V,T,R> 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)

buildReadWriteKeyCommand

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

buildWriteOnlyManyEntriesCommand

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

buildWriteOnlyKeyValueCommand

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

buildWriteOnlyManyCommand

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

buildReadWriteManyCommand

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

buildReadWriteManyEntriesCommand

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

buildTxReadOnlyKeyCommand

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

buildTxReadOnlyManyCommand

<K,V,R> TxReadOnlyManyCommand<K,V,R> buildTxReadOnlyManyCommand(Collection<?> keys,
 List<List<Mutation<K,V,?>>> mutations,
 Params params,
 DataConversion keyDataConversion,
 DataConversion valueDataConversion)

buildBackupMultiKeyAckCommand

BackupMultiKeyAckCommand buildBackupMultiKeyAckCommand(long id,
 int segment,
 int topologyId)

buildExceptionAckCommand

ExceptionAckCommand buildExceptionAckCommand(long id,
 Throwable throwable,
 int topologyId)

buildSingleKeyBackupWriteCommand

SingleKeyBackupWriteCommand buildSingleKeyBackupWriteCommand(ReplaceCommand command,
 long sequence,
 int segmentId)

buildSingleKeyBackupWriteCommand

SingleKeyBackupWriteCommand buildSingleKeyBackupWriteCommand(ComputeIfAbsentCommand command,
 long sequence,
 int segmentId)

buildSingleKeyBackupWriteCommand

SingleKeyBackupWriteCommand buildSingleKeyBackupWriteCommand(ComputeCommand command,
 long sequence,
 int segmentId)

buildSingleKeyBackupWriteCommand

SingleKeyBackupWriteCommand buildSingleKeyBackupWriteCommand(PutKeyValueCommand command,
 long sequence,
 int segmentId)

buildSingleKeyBackupWriteCommand

SingleKeyBackupWriteCommand buildSingleKeyBackupWriteCommand(IracPutKeyValueCommand command,
 long sequence,
 int segmentId)

buildSingleKeyBackupWriteCommand

SingleKeyBackupWriteCommand buildSingleKeyBackupWriteCommand(RemoveCommand command,
 long sequence,
 int segmentId)

buildSingleKeyBackupWriteCommand

<K,V,T,R> SingleKeyFunctionalBackupWriteCommand buildSingleKeyBackupWriteCommand(ReadWriteKeyValueCommand<K,V,T,R> command,
 long sequence,
 int segmentId)

buildSingleKeyBackupWriteCommand

<K,V,R> SingleKeyFunctionalBackupWriteCommand buildSingleKeyBackupWriteCommand(ReadWriteKeyCommand<K,V,R> command,
 long sequence,
 int segmentId)

buildSingleKeyBackupWriteCommand

<K,V> SingleKeyFunctionalBackupWriteCommand buildSingleKeyBackupWriteCommand(WriteOnlyKeyCommand<K,V> command,
 long sequence,
 int segmentId)

buildSingleKeyBackupWriteCommand

<K,V,T> SingleKeyFunctionalBackupWriteCommand buildSingleKeyBackupWriteCommand(WriteOnlyKeyValueCommand<K,V,T> command,
 long sequence,
 int segmentId)

buildPutMapBackupWriteCommand

PutMapBackupWriteCommand buildPutMapBackupWriteCommand(PutMapCommand command,
 Collection<Object> keys,
 long sequence,
 int segmentId)

buildMultiEntriesFunctionalBackupWriteCommand

<K,V,T> MultiEntriesFunctionalBackupWriteCommand buildMultiEntriesFunctionalBackupWriteCommand(WriteOnlyManyEntriesCommand<K,V,T> command,
 Collection<Object> keys,
 long sequence,
 int segmentId)

buildMultiEntriesFunctionalBackupWriteCommand

<K,V,T,R> MultiEntriesFunctionalBackupWriteCommand buildMultiEntriesFunctionalBackupWriteCommand(ReadWriteManyEntriesCommand<K,V,T,R> command,
 Collection<Object> keys,
 long sequence,
 int segmentId)

buildMultiKeyFunctionalBackupWriteCommand

<K,V> MultiKeyFunctionalBackupWriteCommand buildMultiKeyFunctionalBackupWriteCommand(WriteOnlyManyCommand<K,V> command,
 Collection<Object> keys,
 long sequence,
 int segmentId)

buildMultiKeyFunctionalBackupWriteCommand

<K,V,R> MultiKeyFunctionalBackupWriteCommand buildMultiKeyFunctionalBackupWriteCommand(ReadWriteManyCommand<K,V,R> command,
 Collection<Object> keys,
 long sequence,
 int segmentId)

buildBackupNoopCommand

BackupNoopCommand buildBackupNoopCommand(WriteCommand command,
 long sequence,
 int segmentId)

buildKeyReductionPublisherCommand

<K,R>
org.infinispan.reactive.publisher.impl.commands.reduction.ReductionPublisherRequestCommand<K> buildKeyReductionPublisherCommand(boolean parallelStream,
 DeliveryGuarantee deliveryGuarantee,
 org.infinispan.commons.util.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)

buildEntryReductionPublisherCommand

<K,V,R>
org.infinispan.reactive.publisher.impl.commands.reduction.ReductionPublisherRequestCommand<K> buildEntryReductionPublisherCommand(boolean parallelStream,
 DeliveryGuarantee deliveryGuarantee,
 org.infinispan.commons.util.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)

buildInitialPublisherCommand

<K,I,R>
org.infinispan.reactive.publisher.impl.commands.batch.InitialPublisherCommand<K,I,R> buildInitialPublisherCommand(String requestId,
 DeliveryGuarantee deliveryGuarantee,
 int batchSize,
 org.infinispan.commons.util.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)

buildNextPublisherCommand

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

buildCancelPublisherCommand

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

buildMultiClusterEventCommand

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

buildCheckTransactionRpcCommand

CheckTransactionRpcCommand buildCheckTransactionRpcCommand(Collection<GlobalTransaction> globalTransactions)

buildTouchCommand

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

buildIracClearKeysCommand

IracClearKeysRequest buildIracClearKeysCommand()

buildIracCleanupKeyCommand

IracCleanupKeysCommand buildIracCleanupKeyCommand(Collection<IracManagerKeyInfo> state)

buildIracTombstoneCleanupCommand

IracTombstoneCleanupCommand buildIracTombstoneCleanupCommand(int maxCapacity)

buildIracMetadataRequestCommand

IracMetadataRequestCommand buildIracMetadataRequestCommand(int segment,
 IracEntryVersion versionSeen)

buildIracRequestStateCommand

IracRequestStateCommand buildIracRequestStateCommand(org.infinispan.commons.util.IntSet segments)

buildIracStateResponseCommand

IracStateResponseCommand buildIracStateResponseCommand(int capacity)

buildIracPutKeyValueCommand

IracPutKeyValueCommand buildIracPutKeyValueCommand(Object key,
 int segment,
 Object value,
 Metadata metadata,
 PrivateMetadata privateMetadata)

buildIracTouchCommand

IracTouchKeyRequest buildIracTouchCommand(Object key)

buildIracUpdateVersionCommand

IracUpdateVersionCommand buildIracUpdateVersionCommand(Map<Integer, IracEntryVersion> segmentsVersion)

buildXSiteAutoTransferStatusCommand

XSiteAutoTransferStatusCommand buildXSiteAutoTransferStatusCommand(String site)

buildXSiteSetStateTransferModeCommand

XSiteSetStateTransferModeCommand buildXSiteSetStateTransferModeCommand(String site,
 XSiteStateTransferMode mode)

buildIracTombstoneRemoteSiteCheckCommand

IracTombstoneRemoteSiteCheckCommand buildIracTombstoneRemoteSiteCheckCommand(List<Object> keys)

buildIracTombstoneStateResponseCommand

IracTombstoneStateResponseCommand buildIracTombstoneStateResponseCommand(Collection<IracTombstoneInfo> state)

buildIracTombstonePrimaryCheckCommand

IracTombstonePrimaryCheckCommand buildIracTombstonePrimaryCheckCommand(Collection<IracTombstoneInfo> tombstones)

buildIracPutManyCommand

IracPutManyRequest buildIracPutManyCommand(int capacity)

buildXSiteStatePushRequest

@Deprecated(since="16.0",
            forRemoval=true)
default XSiteStatePushRequest buildXSiteStatePushRequest(XSiteState[] chunk,
 long timeoutMillis)

Deprecated, for removal: This API element is subject to removal in a future version.

since 16.0, use buildXSiteStatePushRequest(List, long) instead

buildXSiteStatePushRequest

XSiteStatePushRequest buildXSiteStatePushRequest(List<XSiteState> chunk,
 long timeoutMillis)

buildIracTombstoneCheckRequest

IracTombstoneCheckRequest buildIracTombstoneCheckRequest(List<Object> keys)

buildIracPrimaryPendingKeyCheckCommand

IracPrimaryPendingKeyCheckCommand buildIracPrimaryPendingKeyCheckCommand(List<IracManagerKeyInfo> keys)