Package org.infinispan.commands
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
All Methods Instance Methods Abstract Methods Default Methods Deprecated Methods Modifier and Type Method Description default ApplyDeltaCommand
buildApplyDeltaCommand(Object deltaAwareValueKey, Delta delta, Collection keys)
Deprecated.since 9.1BackupAckCommand
buildBackupAckCommand(long id, int topologyId)
BackupMultiKeyAckCommand
buildBackupMultiKeyAckCommand(long id, int segment, int topologyId)
CancelCommand
buildCancelCommandCommand(UUID commandUUID)
Builds CancelCommandCommand used to cancel other commands executing on Infinispan clusterClearCommand
buildClearCommand(long flagsBitSet)
Builds a ClearCommandClusteredGetAllCommand
buildClusteredGetAllCommand(List<?> keys, long flagsBitSet, GlobalTransaction gtx)
Builds a ClusteredGetAllCommand, which is a remote lookup commandClusteredGetCommand
buildClusteredGetCommand(Object key, int segment, long flagsBitSet)
Builds a ClusteredGetCommand, which is a remote lookup commandCommitCommand
buildCommitCommand(GlobalTransaction gtx)
Builds a CommitCommandCompleteTransactionCommand
buildCompleteTransactionCommand(Xid xid, boolean commit)
Builds a CompleteTransactionCommand command.ComputeCommand
buildComputeCommand(Object key, BiFunction mappingFunction, boolean computeIfPresent, int segment, Metadata metadata, long flagsBitSet)
Builds a ComputeCommandComputeIfAbsentCommand
buildComputeIfAbsentCommand(Object key, Function mappingFunction, int segment, Metadata metadata, long flagsBitSet)
Builds a ComputeIfAbsentCommandCreateCacheCommand
buildCreateCacheCommand(String cacheName, String cacheConfigurationName)
Same asbuildCreateCacheCommand(cacheName, cacheConfigurationName, false, 0)
.CreateCacheCommand
buildCreateCacheCommand(String tmpCacheName, String defaultTmpCacheConfigurationName, int size)
Builds a CreateCacheCommand used to create/start cache around Infinispan cluster<T> DistributedExecuteCommand<T>
buildDistributedExecuteCommand(Callable<T> callable, Address sender, Collection keys)
Builds a DistributedExecuteCommand used for migration and execution of distributed Callables and Runnables.EntrySetCommand
buildEntrySetCommand(long flagsBitSet)
Builds a EntrySetCommandEvictCommand
buildEvictCommand(Object key, int segment, long flagsBitSet)
Builds an EvictCommandExceptionAckCommand
buildExceptionAckCommand(long id, Throwable throwable, int topologyId)
GetAllCommand
buildGetAllCommand(Collection<?> keys, long flagsBitSet, boolean returnEntries)
Builds a GetAllCommandGetCacheEntryCommand
buildGetCacheEntryCommand(Object key, int segment, long flagsBitSet)
Builds a GetCacheEntryCommandGetInDoubtTransactionsCommand
buildGetInDoubtTransactionsCommand()
Builds aGetInDoubtTransactionsCommand
.GetInDoubtTxInfoCommand
buildGetInDoubtTxInfoCommand()
GetKeysInGroupCommand
buildGetKeysInGroupCommand(long flagsBitSet, Object groupName)
BuildsGetKeysInGroupCommand
used to fetch all the keys belonging to a group.GetKeyValueCommand
buildGetKeyValueCommand(Object key, int segment, long flagsBitSet)
Builds a GetKeyValueCommandInvalidateCommand
buildInvalidateCommand(long flagsBitSet, Object... keys)
Builds an InvalidateCommandInvalidateCommand
buildInvalidateFromL1Command(long flagsBitSet, Collection<Object> keys)
Builds an InvalidateFromL1CommandInvalidateCommand
buildInvalidateFromL1Command(Address origin, long flagsBitSet, Collection<Object> keys)
InvalidateVersionsCommand
buildInvalidateVersionsCommand(int topologyId, Object[] keys, int[] topologyIds, long[] versions, boolean removed)
KeySetCommand
buildKeySetCommand(long flagsBitSet)
Builds a KeySetCommandLockControlCommand
buildLockControlCommand(Object key, long flagsBitSet, GlobalTransaction gtx)
Same asbuildLockControlCommand(Object, 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 lockingMultiEntriesFunctionalBackupWriteCommand
buildMultiEntriesFunctionalBackupWriteCommand()
MultiKeyFunctionalBackupWriteCommand
buildMultiKeyFunctionalBackupWriteCommand()
PrepareCommand
buildPrepareCommand(GlobalTransaction gtx, List<WriteCommand> modifications, boolean onePhaseCommit)
Builds a PrepareCommandPutKeyValueCommand
buildPutKeyValueCommand(Object key, Object value, int segment, Metadata metadata, long flagsBitSet)
Builds a PutKeyValueCommandPutMapBackupWriteCommand
buildPutMapBackupWriteCommand()
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)
RemoveCommand
buildRemoveCommand(Object key, Object value, int segment, long flagsBitSet)
Builds a RemoveCommandRemoveExpiredCommand
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 maxIdleRemoveExpiredCommand
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 lifespanRenewBiasCommand
buildRenewBiasCommand(Object[] keys)
ReplaceCommand
buildReplaceCommand(Object key, Object oldValue, Object newValue, int segment, Metadata metadata, long flagsBitSet)
Builds a ReplaceCommandRetrieveLastAccessCommand
buildRetrieveLastAccessCommand(Object key, Object value, int segment)
Builds a retrieve max idle command that is used to get the last access time for a given key.RevokeBiasCommand
buildRevokeBiasCommand(Address ackTarget, long id, int topologyId, Collection<Object> keys)
RollbackCommand
buildRollbackCommand(GlobalTransaction gtx)
Builds a RollbackCommandSingleKeyBackupWriteCommand
buildSingleKeyBackupWriteCommand()
SingleKeyFunctionalBackupWriteCommand
buildSingleKeyFunctionalBackupWriteCommand()
SingleRpcCommand
buildSingleRpcCommand(ReplicableCommand call)
Builds a SingleRpcCommand "envelope" containing a single ReplicableCommandSingleXSiteRpcCommand
buildSingleXSiteRpcCommand(VisitableCommand command)
Builds SingleRpcCommand used to performVisitableCommand
on the backup site,SizeCommand
buildSizeCommand(long flagsBitSet)
Builds a SizeCommandStateRequestCommand
buildStateRequestCommand(StateRequestCommand.Type subtype, Address sender, int topologyId, org.infinispan.commons.util.IntSet segments)
Builds a StateRequestCommand used for requesting transactions and locks and for starting or canceling transfer of cache entries.StateResponseCommand
buildStateResponseCommand(Address sender, int viewId, Collection<StateChunk> stateChunks, boolean applyState, boolean pushTransfer)
Builds a StateResponseCommand used for pushing cache entries to another node in response to a StateRequestCommand.StreamIteratorCloseCommand
buildStreamIteratorCloseCommand(Object id)
StreamIteratorNextCommand
buildStreamIteratorNextCommand(Object id, long batchSize)
<K> StreamIteratorRequestCommand<K>
buildStreamIteratorRequestCommand(Object id, boolean parallelStream, org.infinispan.commons.util.IntSet segments, Set<K> keys, Set<K> excludedKeys, boolean includeLoader, boolean entryStream, Iterable<IntermediateOperation> intOps, long batchSize)
<K> StreamRequestCommand<K>
buildStreamRequestCommand(Object id, boolean parallelStream, StreamRequestCommand.Type type, org.infinispan.commons.util.IntSet segments, Set<K> keys, Set<K> excludedKeys, boolean includeLoader, boolean entryStream, Object terminalOperation)
<R> StreamResponseCommand<R>
buildStreamResponseCommand(Object identifier, boolean complete, org.infinispan.commons.util.IntSet lostSegments, R response)
BuildsStreamResponseCommand
used to send back a response either intermediate or complete to the originating node with the information for the stream request.TxCompletionNotificationCommand
buildTxCompletionNotificationCommand(long internalId)
TxCompletionNotificationCommand
buildTxCompletionNotificationCommand(Xid xid, GlobalTransaction globalTransaction)
Builds aTxCompletionNotificationCommand
.UpdateLastAccessCommand
buildUpdateLastAccessCommand(Object key, int segment, long accessTime)
Builds an update last access command that is used to update the last access time for a given key.VersionedCommitCommand
buildVersionedCommitCommand(GlobalTransaction gtx)
Builds a VersionedCommitCommandVersionedPrepareCommand
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)
XSiteAdminCommand
buildXSiteAdminCommand(String siteName, XSiteAdminCommand.AdminOperation op, Integer afterFailures, Long minTimeToWait)
Builds XSiteAdminCommand used to perform system administrator operations.XSiteStatePushCommand
buildXSiteStatePushCommand(XSiteState[] chunk, long timeoutMillis)
Builds XSiteStatePushCommand used to transfer a single chunk of data between sites.XSiteStateTransferControlCommand
buildXSiteStateTransferControlCommand(XSiteStateTransferControlCommand.StateTransferControl control, String siteName)
Builds XSiteStateTransferControlCommand used to control the-cross site state transfer.String
getCacheName()
Retrieves the cache name this CommandFactory is set up to construct commands for.void
initializeReplicableCommand(ReplicableCommand command, boolean isRemote)
Initializes aReplicableCommand
read from a data stream with components specific to the target cache instance.
-
-
-
Method Detail
-
buildPutKeyValueCommand
PutKeyValueCommand buildPutKeyValueCommand(Object key, Object value, int segment, Metadata metadata, long flagsBitSet)
Builds a PutKeyValueCommand- Parameters:
key
- key to putvalue
- value to putsegment
- the segment of the given keymetadata
- metadata of entryflagsBitSet
- Command flags provided by cache- Returns:
- a PutKeyValueCommand
-
buildRemoveCommand
RemoveCommand buildRemoveCommand(Object key, Object value, int segment, long flagsBitSet)
Builds a RemoveCommand- Parameters:
key
- key to removevalue
- value to check for ina conditional remove, or null for an unconditional remove.segment
- the segment of the given keyflagsBitSet
- Command flags provided by cache- Returns:
- a RemoveCommand
-
buildInvalidateCommand
InvalidateCommand buildInvalidateCommand(long flagsBitSet, Object... keys)
Builds an InvalidateCommand- Parameters:
flagsBitSet
- Command flags provided by cachekeys
- keys to invalidate- Returns:
- an InvalidateCommand
-
buildInvalidateFromL1Command
InvalidateCommand buildInvalidateFromL1Command(long flagsBitSet, Collection<Object> keys)
Builds an InvalidateFromL1Command- Parameters:
flagsBitSet
- Command flags provided by cachekeys
- keys to invalidate- Returns:
- an InvalidateFromL1Command
-
buildInvalidateFromL1Command
InvalidateCommand buildInvalidateFromL1Command(Address origin, long flagsBitSet, Collection<Object> keys)
-
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 entryvalue
- the value of the entry when it was expiredsegment
- the segment of the given keylifespan
- the lifespan that expired from the commandflagsBitSet
- 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 entryvalue
- the value of the entry when it was expiredsegment
- the segment of the given keyflagsBitSet
- Command flags provided by cache- Returns:
- a RemovedExpiredCommand
-
buildRetrieveLastAccessCommand
RetrieveLastAccessCommand buildRetrieveLastAccessCommand(Object key, Object value, int segment)
Builds a retrieve max idle command that is used to get the last access time for a given key.- Parameters:
key
- the key of the entry to get the last access time of- Returns:
- a RetrieveLastAccessCommand
-
buildUpdateLastAccessCommand
UpdateLastAccessCommand buildUpdateLastAccessCommand(Object key, int segment, long accessTime)
Builds an update last access command that is used to update the last access time for a given key.- Parameters:
key
- the key of the entry to update the last access time ofaccessTime
- the time to set the access time to- Returns:
- a UpdateLastAccessCommand
-
buildReplaceCommand
ReplaceCommand buildReplaceCommand(Object key, Object oldValue, Object newValue, int segment, Metadata metadata, long flagsBitSet)
Builds a ReplaceCommand- Parameters:
key
- key to replaceoldValue
- existing value to check for if conditional, null if unconditional.newValue
- value to replace withsegment
- the segment of the given keymetadata
- metadata of entryflagsBitSet
- Command flags provided by cache- 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 absentmappingFunction
- BiFunction for the key and the valuecomputeIfPresent
- flag to apply as computeIfPresent modesegment
- the segment of the given keymetadata
- metadata of entryflagsBitSet
- 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 absentmappingFunction
- mappingFunction for the keysegment
- the segment of the given keymetadata
- metadata of entryflagsBitSet
- Command flags provided by cache- Returns:
- a ComputeCommand
-
buildSizeCommand
SizeCommand buildSizeCommand(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 getsegment
- the segment of the given keyflagsBitSet
- Command flags provided by cache- Returns:
- a GetKeyValueCommand
-
buildGetCacheEntryCommand
GetCacheEntryCommand buildGetCacheEntryCommand(Object key, int segment, long flagsBitSet)
Builds a GetCacheEntryCommand- Parameters:
key
- key to getsegment
- the segment for the keyflagsBitSet
- Command flags provided by cache- Returns:
- a GetCacheEntryCommand
-
buildGetAllCommand
GetAllCommand buildGetAllCommand(Collection<?> keys, long flagsBitSet, boolean returnEntries)
Builds a GetAllCommand- Parameters:
keys
- keys to getflagsBitSet
- Command flags provided by cachereturnEntries
- 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 putmetadata
- metadata of entryflagsBitSet
- 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 evictsegment
- the segment for the keyflagsBitSet
- 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 preparemodifications
- list of modificationsonePhaseCommit
- 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 preparemodifications
- list of modificationsonePhase
-- 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
-
initializeReplicableCommand
void initializeReplicableCommand(ReplicableCommand command, boolean isRemote)
Initializes aReplicableCommand
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.- Parameters:
command
- command to initialize. Cannot be null.isRemote
-
-
buildSingleRpcCommand
SingleRpcCommand buildSingleRpcCommand(ReplicableCommand call)
Builds a SingleRpcCommand "envelope" containing a single ReplicableCommand- Parameters:
call
- ReplicableCommand to include in the envelope- Returns:
- a SingleRpcCommand
-
buildClusteredGetCommand
ClusteredGetCommand buildClusteredGetCommand(Object key, int segment, long flagsBitSet)
Builds a ClusteredGetCommand, which is a remote lookup command- Parameters:
key
- key to look upsegment
- the segment for the keyflagsBitSet
- 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 upflagsBitSet
- 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 lockflagsBitSet
- Command flags provided by cachegtx
-- Returns:
- a LockControlCommand
-
buildLockControlCommand
LockControlCommand buildLockControlCommand(Object key, long flagsBitSet, GlobalTransaction gtx)
Same asbuildLockControlCommand(Object, long, GlobalTransaction)
but for locking a single key vs a collection of keys.
-
buildLockControlCommand
LockControlCommand buildLockControlCommand(Collection<?> keys, long flagsBitSet)
-
buildStateRequestCommand
StateRequestCommand buildStateRequestCommand(StateRequestCommand.Type subtype, Address sender, int topologyId, org.infinispan.commons.util.IntSet segments)
Builds a StateRequestCommand used for requesting transactions and locks and for starting or canceling transfer of cache entries.
-
buildStateResponseCommand
StateResponseCommand buildStateResponseCommand(Address sender, int viewId, Collection<StateChunk> stateChunks, boolean applyState, boolean pushTransfer)
Builds a StateResponseCommand used for pushing cache entries to another node in response to a StateRequestCommand.
-
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 aGetInDoubtTransactionsCommand
.
-
buildTxCompletionNotificationCommand
TxCompletionNotificationCommand buildTxCompletionNotificationCommand(Xid xid, GlobalTransaction globalTransaction)
Builds aTxCompletionNotificationCommand
.
-
buildDistributedExecuteCommand
<T> DistributedExecuteCommand<T> buildDistributedExecuteCommand(Callable<T> callable, Address sender, Collection keys)
Builds a DistributedExecuteCommand used for migration and execution of distributed Callables and Runnables.- Parameters:
callable
- the callable tasksender
- sender's Addresskeys
- keys used in Callable- Returns:
- a DistributedExecuteCommand
-
buildGetInDoubtTxInfoCommand
GetInDoubtTxInfoCommand buildGetInDoubtTxInfoCommand()
- See Also:
GetInDoubtTxInfoCommand
-
buildCompleteTransactionCommand
CompleteTransactionCommand buildCompleteTransactionCommand(Xid 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
-
buildApplyDeltaCommand
@Deprecated default ApplyDeltaCommand buildApplyDeltaCommand(Object deltaAwareValueKey, Delta delta, Collection keys)
Deprecated.since 9.1Builds a ApplyDeltaCommand used for applying Delta objects to DeltaAware containers stored in cache- Returns:
- ApplyDeltaCommand instance
- See Also:
ApplyDeltaCommand
-
buildCreateCacheCommand
CreateCacheCommand buildCreateCacheCommand(String cacheName, String cacheConfigurationName)
Same asbuildCreateCacheCommand(cacheName, cacheConfigurationName, false, 0)
.
-
buildCreateCacheCommand
CreateCacheCommand buildCreateCacheCommand(String tmpCacheName, String defaultTmpCacheConfigurationName, int size)
Builds a CreateCacheCommand used to create/start cache around Infinispan cluster- Parameters:
size
- Ifsize > 0
, the command will wait until the cache runs on at leastsize
nodes.
-
buildCancelCommandCommand
CancelCommand buildCancelCommandCommand(UUID commandUUID)
Builds CancelCommandCommand used to cancel other commands executing on Infinispan cluster- Parameters:
commandUUID
- UUID for command to cancel- Returns:
- created CancelCommandCommand
-
buildXSiteStateTransferControlCommand
XSiteStateTransferControlCommand buildXSiteStateTransferControlCommand(XSiteStateTransferControlCommand.StateTransferControl control, String siteName)
Builds XSiteStateTransferControlCommand used to control the-cross site state transfer.- Parameters:
control
- the control operationsiteName
- the site name, needed for some control operations.- Returns:
- the XSiteStateTransferControlCommand created
-
buildXSiteAdminCommand
XSiteAdminCommand buildXSiteAdminCommand(String siteName, XSiteAdminCommand.AdminOperation op, Integer afterFailures, Long minTimeToWait)
Builds XSiteAdminCommand used to perform system administrator operations.- Returns:
- the XSiteAdminCommand created
-
buildXSiteStatePushCommand
XSiteStatePushCommand buildXSiteStatePushCommand(XSiteState[] chunk, long timeoutMillis)
Builds XSiteStatePushCommand used to transfer a single chunk of data between sites.- Parameters:
chunk
- the data chunktimeoutMillis
- timeout in milliseconds, for the retries in the receiver site.- Returns:
- the XSiteStatePushCommand created
-
buildSingleXSiteRpcCommand
SingleXSiteRpcCommand buildSingleXSiteRpcCommand(VisitableCommand command)
Builds SingleRpcCommand used to performVisitableCommand
on the backup site,- Parameters:
command
- the visitable command.- Returns:
- the SingleXSiteRpcCommand created
-
buildGetKeysInGroupCommand
GetKeysInGroupCommand buildGetKeysInGroupCommand(long flagsBitSet, Object groupName)
BuildsGetKeysInGroupCommand
used to fetch all the keys belonging to a group.- Parameters:
flagsBitSet
- Command flags provided by cachegroupName
- the group name.- Returns:
- the GetKeysInGroup created.
-
buildStreamRequestCommand
<K> StreamRequestCommand<K> buildStreamRequestCommand(Object id, boolean parallelStream, StreamRequestCommand.Type type, org.infinispan.commons.util.IntSet segments, Set<K> keys, Set<K> excludedKeys, boolean includeLoader, boolean entryStream, Object terminalOperation)
-
buildStreamResponseCommand
<R> StreamResponseCommand<R> buildStreamResponseCommand(Object identifier, boolean complete, org.infinispan.commons.util.IntSet lostSegments, R response)
BuildsStreamResponseCommand
used to send back a response either intermediate or complete to the originating node with the information for the stream request.- Type Parameters:
R
- type of response- Parameters:
identifier
- the unique identifier for the stream requestcomplete
- whether or not this is an intermediate or final response from this node for the given idlostSegments
- what segments that were lost during processingresponse
- the actual response- Returns:
- the command to send back the response
-
buildStreamIteratorRequestCommand
<K> StreamIteratorRequestCommand<K> buildStreamIteratorRequestCommand(Object id, boolean parallelStream, org.infinispan.commons.util.IntSet segments, Set<K> keys, Set<K> excludedKeys, boolean includeLoader, boolean entryStream, Iterable<IntermediateOperation> intOps, long batchSize)
-
buildStreamIteratorNextCommand
StreamIteratorNextCommand buildStreamIteratorNextCommand(Object id, long batchSize)
-
buildStreamIteratorCloseCommand
StreamIteratorCloseCommand buildStreamIteratorCloseCommand(Object id)
-
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)
-
buildBackupAckCommand
BackupAckCommand buildBackupAckCommand(long id, int topologyId)
-
buildBackupMultiKeyAckCommand
BackupMultiKeyAckCommand buildBackupMultiKeyAckCommand(long id, int segment, int topologyId)
-
buildExceptionAckCommand
ExceptionAckCommand buildExceptionAckCommand(long id, Throwable throwable, int topologyId)
-
buildInvalidateVersionsCommand
InvalidateVersionsCommand buildInvalidateVersionsCommand(int topologyId, Object[] keys, int[] topologyIds, long[] versions, boolean removed)
-
buildRevokeBiasCommand
RevokeBiasCommand buildRevokeBiasCommand(Address ackTarget, long id, int topologyId, Collection<Object> keys)
-
buildRenewBiasCommand
RenewBiasCommand buildRenewBiasCommand(Object[] keys)
-
buildSingleKeyBackupWriteCommand
SingleKeyBackupWriteCommand buildSingleKeyBackupWriteCommand()
-
buildSingleKeyFunctionalBackupWriteCommand
SingleKeyFunctionalBackupWriteCommand buildSingleKeyFunctionalBackupWriteCommand()
-
buildPutMapBackupWriteCommand
PutMapBackupWriteCommand buildPutMapBackupWriteCommand()
-
buildMultiEntriesFunctionalBackupWriteCommand
MultiEntriesFunctionalBackupWriteCommand buildMultiEntriesFunctionalBackupWriteCommand()
-
buildMultiKeyFunctionalBackupWriteCommand
MultiKeyFunctionalBackupWriteCommand buildMultiKeyFunctionalBackupWriteCommand()
-
-