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.marshall.exts |
Externalizers for various JDK types that are marshalled using the marshalling framework.
|
org.infinispan.query.clustered | |
org.infinispan.query.impl | |
org.infinispan.query.indexmanager | |
org.infinispan.remoting |
Remote communication between cache instances.
|
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.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 |
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 |
ExtendedModuleCommandFactory.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 |
ClusteredGetCommand
Issues a remote get call.
|
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 | 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 | Class and Description |
---|---|
class |
ClusteredQueryCommand
Encapsulates all rpc calls for distributed queries actions
|
Modifier and Type | Method and Description |
---|---|
CacheRpcCommand |
CommandFactory.fromStream(byte commandId,
Object[] args,
String cacheName) |
Modifier and Type | Class and Description |
---|---|
class |
IndexUpdateCommand
Custom RPC command containing an index update request for the
Master IndexManager of a specific cache & index.
|
Modifier and Type | Method and Description |
---|---|
void |
InboundInvocationHandler.handle(CacheRpcCommand command,
Address origin,
org.jgroups.blocks.Response response,
boolean preserveOrder)
Invokes a command on the cache, from a remote source.
|
void |
InboundInvocationHandlerImpl.handle(CacheRpcCommand cmd,
Address origin,
org.jgroups.blocks.Response response,
boolean preserveOrder) |
Modifier and Type | Method and Description |
---|---|
Response |
ResponseGenerator.getResponse(CacheRpcCommand command,
Object returnValue) |
Response |
DefaultResponseGenerator.getResponse(CacheRpcCommand command,
Object returnValue) |
Response |
DistributionResponseGenerator.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 | Method and Description |
---|---|
Collection<Class<? extends CacheRpcCommand>> |
ModuleProperties.moduleCacheRpcCommands() |
Modifier and Type | Class and Description |
---|---|
class |
XSiteAdminCommand
Command used for handling XSiteReplication administrative operations.
|
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.