Package | Description |
---|---|
org.infinispan.commands |
Commands that operate on the cache, either locally or remotely.
|
org.infinispan.commands.control | |
org.infinispan.commands.functional | |
org.infinispan.commands.irac | |
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.statetransfer | |
org.infinispan.commands.tx |
Commands that represent transactional lifecycle transitions.
|
org.infinispan.commands.write |
Commands that alter the state of the cache.
|
org.infinispan.expiration.impl | |
org.infinispan.interceptors.distribution |
Interceptors dealing with command replication in distributed/replicated mode.
|
org.infinispan.interceptors.impl |
Basic interceptors
|
org.infinispan.reactive.publisher.impl.commands.batch | |
org.infinispan.reactive.publisher.impl.commands.reduction | |
org.infinispan.statetransfer |
Transfer of state to new caches in a cluster.
|
Modifier and Type | Interface and Description |
---|---|
interface |
DataCommand
Commands of this type manipulate data in the cache.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractTopologyAffectedCommand
Base class for commands that carry topology id.
|
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 |
AbstractWriteKeyCommand<K,V> |
class |
AbstractWriteManyCommand<K,V> |
class |
ReadOnlyKeyCommand<K,V,R> |
class |
ReadOnlyManyCommand<K,V,R> |
class |
ReadWriteKeyCommand<K,V,R> |
class |
ReadWriteKeyValueCommand<K,V,T,R> |
class |
ReadWriteManyCommand<K,V,R> |
class |
ReadWriteManyEntriesCommand<K,V,T,R> |
class |
TxReadOnlyKeyCommand<K,V,R> |
class |
TxReadOnlyManyCommand<K,V,R> |
class |
WriteOnlyKeyCommand<K,V> |
class |
WriteOnlyKeyValueCommand<K,V,T> |
class |
WriteOnlyManyCommand<K,V> |
class |
WriteOnlyManyEntriesCommand<K,V,T> |
Modifier and Type | Class and Description |
---|---|
class |
IracMetadataRequestCommand
A request for a new
IracMetadata for a giver segment. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractDataCommand |
class |
GetAllCommand
Retrieves multiple entries at once.
|
class |
GetCacheEntryCommand
Used to fetch a full CacheEntry rather than just the value.
|
class |
GetKeyValueCommand
Implements functionality defined by
Map.get(Object) and
Map.containsKey(Object) operations |
Modifier and Type | Class and Description |
---|---|
class |
BaseClusteredReadCommand |
class |
ClusteredGetAllCommand<K,V>
Issues a remote getAll call.
|
class |
ClusteredGetCommand
Issues a remote get call.
|
class |
GetKeysInGroupCommand
VisitableCommand that fetches the keys belonging to a group. |
Modifier and Type | Class and Description |
---|---|
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 | 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 |
DataWriteCommand
Mixes features from DataCommand and WriteCommand
|
interface |
WriteCommand
A command that modifies the cache in some way
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractDataWriteCommand
Stuff common to WriteCommands
|
class |
ClearCommand |
class |
ComputeCommand |
class |
ComputeIfAbsentCommand |
class |
EvictCommand |
class |
InvalidateCommand
Removes an entry from memory.
|
class |
InvalidateL1Command
Invalidates an entry in a L1 cache (used with DIST mode)
|
class |
PutKeyValueCommand
Implements functionality defined by
BasicCache.put(Object, Object) |
class |
PutMapCommand
A command writing multiple key/value pairs with the same metadata.
|
class |
RemoveCommand |
class |
RemoveExpiredCommand
Removes an entry that is expired from memory
|
class |
ReplaceCommand |
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 LocalizedCacheTopology |
BaseDistributionInterceptor.checkTopologyId(TopologyAffectedCommand command) |
Modifier and Type | Method and Description |
---|---|
protected <C extends VisitableCommand & TopologyAffectedCommand & FlagAffectedCommand> |
BaseStateTransferInterceptor.handleReadCommand(InvocationContext ctx,
C command) |
Modifier and Type | Method and Description |
---|---|
protected int |
BaseStateTransferInterceptor.getNewTopologyId(Throwable ce,
int currentTopologyId,
TopologyAffectedCommand command) |
protected void |
BaseStateTransferInterceptor.logRetry(int currentTopologyId,
TopologyAffectedCommand cmd) |
protected void |
BaseStateTransferInterceptor.updateTopologyId(TopologyAffectedCommand command) |
Modifier and Type | Class and Description |
---|---|
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 |
---|---|
Map<Address,Response> |
StateTransferManager.forwardCommandIfNeeded(TopologyAffectedCommand command,
Set<Object> affectedKeys,
Address origin)
If there is an state transfer happening at the moment, this method forwards the supplied
command to the nodes that are new owners of the data, in order to assure consistency.
|
Map<Address,Response> |
StateTransferManagerImpl.forwardCommandIfNeeded(TopologyAffectedCommand command,
Set<Object> affectedKeys,
Address origin) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.