Modifier and Type | Method and Description |
---|---|
CacheRpcCommand |
RemoteCommandsFactory.fromStream(byte id,
byte type,
ByteString cacheName)
Resolve an
CacheRpcCommand from the stream. |
Modifier and Type | Class and Description |
---|---|
class |
LockControlCommand
LockControlCommand is a command that enables distributed locking across infinispan nodes.
|
Modifier and Type | Class and Description |
---|---|
class |
IracCleanupKeyCommand
Sends a cleanup request from primary owner to backup owners.
|
class |
IracClearKeysCommand
A clear request that is sent to the remote site by
IracManager . |
class |
IracMetadataRequestCommand
A request for a new
IracMetadata for a giver segment. |
class |
IracPutKeyCommand
A put key request that is sent to the remote site by
IracManager . |
class |
IracRemoveKeyCommand
A remove key request that is sent to the remote site by
IracManager . |
class |
IracRequestStateCommand
Requests the state for a given segments.
|
class |
IracStateResponseCommand
The IRAC state for a given key.
|
class |
IracUpdateKeyCommand
An update request that is sent to the remote site by
IracManager . |
Modifier and Type | Method and Description |
---|---|
CacheRpcCommand |
ModuleCommandFactory.fromStream(byte commandId,
ByteString cacheName)
Construct and initialize a
CacheRpcCommand based on the command id. |
Modifier and Type | Class and Description |
---|---|
class |
BaseClusteredReadCommand |
class |
BaseRpcCommand |
class |
CheckTransactionRpcCommand
|
class |
ClusteredGetAllCommand<K,V>
Issues a remote getAll call.
|
class |
ClusteredGetCommand
Issues a remote get call.
|
class |
RenewBiasCommand |
class |
RevokeBiasCommand
Informs node that it is not allowed to serve reads from the local record anymore.
|
class |
SingleRpcCommand
Aggregates a single command for replication.
|
Modifier and Type | Class and Description |
---|---|
class |
CompleteTransactionCommand
Command used by the recovery tooling for forcing transaction completion .
|
class |
GetInDoubtTransactionsCommand
Rpc to obtain all in-doubt prepared transactions stored on remote nodes.
|
class |
GetInDoubtTxInfoCommand
Command used by the recovery tooling for obtaining the list of in-doubt transactions from a node.
|
class |
RecoveryCommand
Deprecated.
since 11.0, class will be removed with no direct replacement. BaseRpcCommand should be extended instead.
|
class |
TxCompletionNotificationCommand
Command for removing recovery related information from the cluster.
|
Modifier and Type | Class and Description |
---|---|
class |
ConflictResolutionStartCommand
Start conflict resolution.
|
class |
ScatteredStateConfirmRevokedCommand
|
class |
ScatteredStateGetKeysCommand
Start transferring keys and remote metadata for the given segments.
|
class |
StateResponseCommand
This command is used by a StateProvider to push cache entries to a StateConsumer.
|
class |
StateTransferCancelCommand
Cancel state transfer.
|
class |
StateTransferGetListenersCommand
Get the registered cluster listeners.
|
class |
StateTransferGetTransactionsCommand
Get transactions for the specified segments.
|
class |
StateTransferStartCommand
Start state transfer.
|
Modifier and Type | Class and Description |
---|---|
class |
BackupWriteCommand
A write operation sent from the primary owner to the backup owners.
|
class |
MultiEntriesFunctionalBackupWriteCommand
|
class |
MultiKeyFunctionalBackupWriteCommand
|
class |
PutMapBackupWriteCommand
A
BackupWriteCommand implementation for PutMapCommand . |
class |
SingleKeyBackupWriteCommand
A single key
BackupWriteCommand for single key non-functional commands. |
class |
SingleKeyFunctionalBackupWriteCommand
A single key
BackupWriteCommand for single key functional commands. |
Modifier and Type | Interface and Description |
---|---|
interface |
TransactionBoundaryCommand
An transaction boundary command that allows the retrieval of an attached
GlobalTransaction |
Modifier and Type | Class and Description |
---|---|
class |
AbstractTransactionBoundaryCommand
An abstract transaction boundary command that holds a reference to a
GlobalTransaction |
class |
CommitCommand
Command corresponding to the 2nd phase of 2PC.
|
class |
PrepareCommand
Command corresponding to the 1st phase of 2PC.
|
class |
RollbackCommand
Command corresponding to a transaction rollback.
|
class |
VersionedCommitCommand
The same as a
CommitCommand except that version information is also carried by this command, used by
optimistically transactional caches making use of write skew checking when using IsolationLevel.REPEATABLE_READ . |
class |
VersionedPrepareCommand
Same as
PrepareCommand except that the transaction originator makes evident the versions of entries touched
and stored in a transaction context so that accurate write skew checks may be performed by the lock owner(s). |
Modifier and Type | Class and Description |
---|---|
class |
BackupAckCommand
A command that represents an acknowledge sent by a backup owner to the originator.
|
class |
BackupMultiKeyAckCommand
A command that represents an acknowledge sent by a backup owner to the originator.
|
class |
ExceptionAckCommand
A command that represents an exception acknowledge sent by any owner.
|
class |
InvalidateVersionsCommand
Must be
VisitableCommand as we want to catch it in persistence handling etc. |
Modifier and Type | Class and Description |
---|---|
class |
TouchCommand
This command updates a cache entry's last access timestamp.
|
Modifier and Type | Method and Description |
---|---|
protected CacheRpcCommand |
ReplicableCommandExternalizer.fromStream(byte id,
byte type,
ByteString cacheName) |
CacheRpcCommand |
CacheRpcCommandExternalizer.readObject(ObjectInput input) |
CacheRpcCommand |
TriangleAckExternalizer.readObject(ObjectInput input) |
Modifier and Type | Method and Description |
---|---|
Set<Class<? extends CacheRpcCommand>> |
CacheRpcCommandExternalizer.getTypeClasses() |
Set<Class<? extends CacheRpcCommand>> |
TriangleAckExternalizer.getTypeClasses() |
Modifier and Type | Method and Description |
---|---|
void |
CacheRpcCommandExternalizer.writeObject(ObjectOutput output,
CacheRpcCommand command) |
void |
TriangleAckExternalizer.writeObject(ObjectOutput output,
CacheRpcCommand object) |
Modifier and Type | Class and Description |
---|---|
class |
MultiClusterEventCommand<K,V>
This command is used to send cluster events for multiple listeners on the same node
|
Modifier and Type | Class and Description |
---|---|
class |
CancelPublisherCommand |
class |
InitialPublisherCommand<K,I,R> |
class |
NextPublisherCommand |
Modifier and Type | Class and Description |
---|---|
class |
ReductionPublisherRequestCommand<K>
Stream request command that is sent to remote nodes handle execution of remote intermediate and terminal operations.
|
Modifier and Type | Method and Description |
---|---|
static LocalInvocation |
LocalInvocation.newInstance(ComponentRegistry componentRegistry,
CacheRpcCommand command) |
static LocalInvocation |
LocalInvocation.newInstanceFromCache(Cache<?,?> cache,
CacheRpcCommand command) |
Modifier and Type | Field and Description |
---|---|
protected CacheRpcCommand |
BaseBlockingRunnable.command |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractDelegatingHandler.afterHandle(CacheRpcCommand command,
DeliverOrder order,
boolean delegated)
Invoked after the command is handled.
|
protected boolean |
AbstractDelegatingHandler.beforeHandle(CacheRpcCommand command,
Reply reply,
DeliverOrder order)
Invoked before the command is handled by the real
PerCacheInboundInvocationHandler . |
void |
AbstractDelegatingHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order) |
void |
NonTxPerCacheInboundInvocationHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order) |
void |
PerCacheInboundInvocationHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order)
Handles the
CacheRpcCommand from other node. |
void |
TrianglePerCacheInboundInvocationHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order) |
void |
TxPerCacheInboundInvocationHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order) |
Constructor and Description |
---|
BaseBlockingRunnable(BasePerCacheInboundInvocationHandler handler,
CacheRpcCommand command,
Reply reply,
boolean sync) |
DefaultTopologyRunnable(BasePerCacheInboundInvocationHandler handler,
CacheRpcCommand command,
Reply reply,
TopologyMode topologyMode,
int commandTopologyId,
boolean sync) |
Modifier and Type | Method and Description |
---|---|
Response |
DefaultResponseGenerator.getResponse(CacheRpcCommand command,
Object returnValue) |
Response |
ResponseGenerator.getResponse(CacheRpcCommand command,
Object returnValue) |
Modifier and Type | Method and Description |
---|---|
Collection<Class<? extends CacheRpcCommand>> |
ModuleProperties.moduleCacheRpcCommands()
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
SingleXSiteRpcCommand
RPC command to replicate cache operations (such as put, remove, replace, etc.) to the backup site.
|
class |
XSiteReplicateCommand
Abstract class to invoke RPC on the remote site.
|
Modifier and Type | Class and Description |
---|---|
class |
XSiteAmendOfflineStatusCommand
Amend a sites offline status.
|
class |
XSiteBringOnlineCommand
Take a site offline.
|
class |
XSiteOfflineStatusCommand
Get the offline status of a
BackupSender . |
class |
XSiteStateTransferCancelSendCommand
Cancel sending XSite state.
|
class |
XSiteStateTransferClearStatusCommand
Clear XSite state transfer status.
|
class |
XSiteStateTransferFinishReceiveCommand
Finish receiving XSite state.
|
class |
XSiteStateTransferFinishSendCommand
Finish sending XSite state.
|
class |
XSiteStateTransferRestartSendingCommand
Restart sending XSite state.
|
class |
XSiteStateTransferStartReceiveCommand
Start receiving XSite state.
|
class |
XSiteStateTransferStartSendCommand
Start send XSite state.
|
class |
XSiteStateTransferStatusRequestCommand
Get XSite state transfer status.
|
class |
XSiteStatusCommand
Return the status of a
BackupSender . |
class |
XSiteTakeOfflineCommand
Take a site offline.
|
Modifier and Type | Class and Description |
---|---|
class |
XSiteStatePushCommand
Wraps the state to be sent to another site
|
Copyright © 2021 JBoss by Red Hat. All rights reserved.