Package | Description |
---|---|
org.infinispan.commands |
Commands that operate on the cache, either locally or remotely.
|
org.infinispan.commands.control | |
org.infinispan.commands.module | |
org.infinispan.commands.read | |
org.infinispan.commands.remote |
Meta-commands that wrap other commands for remote execution.
|
org.infinispan.commands.remote.recovery | |
org.infinispan.commands.tx |
Commands that represent transactional lifecycle transitions.
|
org.infinispan.commands.tx.totalorder | |
org.infinispan.iteration.impl |
Provides Infinispan-specific implementation details iterating over entries in the cache, specifically optimized for
distributed caches.
|
org.infinispan.marshall.exts |
Externalizers for various JDK types that are marshalled using the marshalling framework.
|
org.infinispan.remoting |
Remote communication between cache instances.
|
org.infinispan.remoting.inboundhandler | |
org.infinispan.remoting.responses |
Abstractions of the different response types allowed during RPC.
|
org.infinispan.statetransfer |
Transfer of state to new caches in a cluster.
|
org.infinispan.stream.impl | |
org.infinispan.util |
General utilities that are not specific to Infinispan, including string parsing helpers, reflection tools and
collections and containers designed to supplement the JDK-provided containers.
|
org.infinispan.xsite | |
org.infinispan.xsite.statetransfer |
Modifier and Type | Interface and Description |
---|---|
interface |
CancellableCommand
CancellableCommand is a command whose execution in remote VM can be canceled (if needed)
|
Modifier and Type | Class and Description |
---|---|
class |
CancelCommand
Command to cancel commands executing in remote VM
|
class |
CreateCacheCommand
Command to create/start a cache on a subset of Infinispan cluster nodes
|
class |
RemoveCacheCommand
Command to stop a cache and remove all its contents from both
memory and any backing store.
|
Modifier and Type | Method and Description |
---|---|
CacheRpcCommand |
RemoteCommandsFactory.fromStream(byte id,
Object[] parameters,
byte type,
String 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 | Method and Description |
---|---|
CacheRpcCommand |
ModuleCommandFactory.fromStream(byte commandId,
Object[] args,
String cacheName)
Construct and initialize a
CacheRpcCommand based on the command
id and argument array passed in. |
Modifier and Type | Class and Description |
---|---|
class |
DistributedExecuteCommand<V>
DistributedExecuteCommand is used to migrate Callable and execute it in remote JVM.
|
class |
MapCombineCommand<KIn,VIn,KOut,VOut>
|
class |
ReduceCommand<KOut,VOut>
ReduceCommand is a container to migrate
Reducer to a remote Infinispan node where it will
get executed and return the result to an invoking/master node. |
Modifier and Type | Class and Description |
---|---|
class |
BaseRpcCommand |
class |
BaseRpcInvokingCommand
Base class for RPC commands.
|
class |
ClusteredGetAllCommand<K,V>
Issues a remote getAll call.
|
class |
ClusteredGetCommand
Issues a remote get call.
|
class |
LocalFlagAffectedRpcCommand |
class |
MultipleRpcCommand
Command that implements cluster replication logic.
|
class |
SingleRpcCommand
Similar to
MultipleRpcCommand , but it only 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
Base class for recovery-related rpc-commands.
|
class |
TxCompletionNotificationCommand
Command for removing recovery related information from the cluster.
|
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 | Interface and Description |
---|---|
interface |
TotalOrderPrepareCommand
Interface with the utilities methods that the prepare command must have when Total Order based protocol is used
|
Modifier and Type | Class and Description |
---|---|
class |
TotalOrderCommitCommand
Commit Command used in the 2nd phase of 2PC.
|
class |
TotalOrderNonVersionedPrepareCommand
Command corresponding to the 1st phase of 2PC when Total Order based protocol is used.
|
class |
TotalOrderRollbackCommand
The 2nd phase command of 2PC, used when a transaction must be aborted.
|
class |
TotalOrderVersionedCommitCommand
Command corresponding to the 2nd phase of 2PC.
|
class |
TotalOrderVersionedPrepareCommand
Command corresponding to the 1st phase of 2PC when Total Order based protocol is used.
|
Modifier and Type | Class and Description |
---|---|
class |
EntryRequestCommand<K,V,C>
Command sent to request entry iterator values for given segments.
|
class |
EntryResponseCommand<K,C>
Command sent to respond with entry values for given segments
|
Modifier and Type | Method and Description |
---|---|
protected CacheRpcCommand |
ReplicableCommandExternalizer.fromStream(byte id,
Object[] parameters,
byte type,
String cacheName) |
CacheRpcCommand |
CacheRpcCommandExternalizer.readObject(ObjectInput input) |
Modifier and Type | Method and Description |
---|---|
Set<Class<? extends CacheRpcCommand>> |
CacheRpcCommandExternalizer.getTypeClasses() |
Modifier and Type | Method and Description |
---|---|
void |
CacheRpcCommandExternalizer.writeObject(ObjectOutput output,
CacheRpcCommand command) |
Modifier and Type | Method and Description |
---|---|
static LocalInvocation |
LocalInvocation.newInstance(ResponseGenerator responseGenerator,
CacheRpcCommand command,
CommandsFactory commandsFactory,
Address self) |
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 . |
protected BlockingRunnable |
BasePerCacheInboundInvocationHandler.createDefaultRunnable(CacheRpcCommand command,
Reply reply,
int commandTopologyId,
boolean waitTransactionalData,
boolean onExecutorService) |
protected BlockingRunnable |
NonTotalOrderTxPerCacheInboundInvocationHandler.createReadyActionRunnable(CacheRpcCommand command,
Reply reply,
int commandTopologyId,
boolean waitTransactionalData,
boolean onExecutorService,
ReadyAction readyAction) |
protected boolean |
BasePerCacheInboundInvocationHandler.executeOnExecutorService(DeliverOrder order,
CacheRpcCommand command) |
protected static int |
BasePerCacheInboundInvocationHandler.extractCommandTopologyId(CacheRpcCommand command) |
void |
NonTotalOrderTxPerCacheInboundInvocationHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order) |
void |
AbstractDelegatingHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order) |
void |
NonTotalOrderPerCacheInboundInvocationHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order) |
void |
TotalOrderTxPerCacheInboundInvocationHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order) |
void |
PerCacheInboundInvocationHandler.handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order)
Handles the
CacheRpcCommand from other node. |
Constructor and Description |
---|
BaseBlockingRunnable(BasePerCacheInboundInvocationHandler handler,
CacheRpcCommand command,
Reply reply) |
DefaultTopologyRunnable(BasePerCacheInboundInvocationHandler handler,
CacheRpcCommand command,
Reply reply,
TopologyMode topologyMode,
int commandTopologyId) |
Modifier and Type | Method and Description |
---|---|
Response |
DefaultResponseGenerator.getResponse(CacheRpcCommand command,
Object returnValue) |
Response |
ResponseGenerator.getResponse(CacheRpcCommand command,
Object returnValue) |
Modifier and Type | Class and Description |
---|---|
class |
StateRequestCommand
This command is used by a StateConsumer to request transactions and cache entries from a StateProvider.
|
class |
StateResponseCommand
This command is used by a StateProvider to push cache entries to a StateConsumer.
|
Modifier and Type | Class and Description |
---|---|
class |
StreamRequestCommand<K>
Stream request command that is sent to remote nodes handle execution of remote intermediate and terminal operations.
|
class |
StreamResponseCommand<R>
Stream response command used to handle returning intermediate or final responses from the remote node
|
class |
StreamSegmentResponseCommand<R>
A stream response command taht also returns back suspected segments that need to be retried
|
Modifier and Type | Method and Description |
---|---|
Collection<Class<? extends CacheRpcCommand>> |
ModuleProperties.moduleCacheRpcCommands() |
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 |
XSiteAdminCommand
Command used for handling XSiteReplication administrative operations.
|
class |
XSiteReplicateCommand
Abstract class to invoke RPC on the remote site.
|
Modifier and Type | Class and Description |
---|---|
class |
XSiteStatePushCommand
Wraps the state to be sent to another site
|
class |
XSiteStateTransferControlCommand
Command used to control the state transfer between sites.
|
Copyright © 2021 JBoss, a division of Red Hat. All rights reserved.