Package | Description |
---|---|
org.infinispan.cache.impl | |
org.infinispan.commands |
Commands that operate on the cache, either locally or remotely.
|
org.infinispan.commands.control | |
org.infinispan.commands.functional | |
org.infinispan.commands.read | |
org.infinispan.commands.remote |
Meta-commands that wrap other commands for remote execution.
|
org.infinispan.commands.tx |
Commands that represent transactional lifecycle transitions.
|
org.infinispan.commands.write |
Commands that alter the state of the cache.
|
org.infinispan.context |
Contexts contain information of a specific invocation on the cache, such as its origins, scope
(transactional or non-transactional), as well as invocation-specific flags.
|
org.infinispan.context.impl |
This package contains different context implementations, selected dynamically based on the type of invocation.
|
org.infinispan.functional.impl | |
org.infinispan.interceptors |
Infinispan is designed around a set of interceptors around a data container.
|
org.infinispan.interceptors.distribution |
Interceptors dealing with command replication in distributed/replicated mode.
|
org.infinispan.interceptors.impl |
Basic interceptors
|
org.infinispan.interceptors.locking |
Interceptors dealing with locking.
|
org.infinispan.partitionhandling.impl | |
org.infinispan.statetransfer |
Transfer of state to new caches in a cluster.
|
org.infinispan.xsite |
Modifier and Type | Interface and Description |
---|---|
interface |
DataCommand
Commands of this type manipulate data in the cache.
|
interface |
FlagAffectedCommand
Flags modify behavior of command such as whether or not to invoke certain commands remotely, check cache store etc.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractFlagAffectedCommand
Base class for those commands that can carry flags.
|
class |
AbstractTopologyAffectedCommand
Base class for commands that carry topology id.
|
Modifier and Type | Method and Description |
---|---|
SingleRpcCommand |
CommandsFactory.buildSingleRpcCommand(VisitableCommand command)
Builds a SingleRpcCommand "envelope" containing a single ReplicableCommand
|
SingleRpcCommand |
CommandsFactoryImpl.buildSingleRpcCommand(VisitableCommand call) |
SingleXSiteRpcCommand |
CommandsFactory.buildSingleXSiteRpcCommand(VisitableCommand command)
Builds SingleRpcCommand used to perform
VisitableCommand on the backup site, |
SingleXSiteRpcCommand |
CommandsFactoryImpl.buildSingleXSiteRpcCommand(VisitableCommand command) |
protected Object |
AbstractVisitor.handleDefault(InvocationContext ctx,
VisitableCommand command)
A default handler for all commands visited.
|
Object |
AbstractVisitor.visitUnknownCommand(InvocationContext ctx,
VisitableCommand command) |
Object |
Visitor.visitUnknownCommand(InvocationContext ctx,
VisitableCommand command)
Deprecated.
since 11.0 will be removed in the next major version with no direct replacement. There is no reason
that a unknown command should be passed through the interceptor chain.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractVisitor.visitCollection(InvocationContext ctx,
Collection<? extends VisitableCommand> toVisit)
Helper method to visit a collection of VisitableCommands.
|
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 |
AbstractDataCommand |
class |
AbstractLocalCommand
Abstract class
|
class |
EntrySetCommand<K,V>
Command implementation for
Map.entrySet() functionality. |
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 |
class |
KeySetCommand<K,V>
Command implementation for
Map.keySet() functionality. |
class |
SizeCommand
Command to calculate the size of the cache
|
Modifier and Type | Class and Description |
---|---|
class |
GetKeysInGroupCommand
VisitableCommand that fetches the keys belonging to a group. |
Constructor and Description |
---|
SingleRpcCommand(ByteString cacheName,
VisitableCommand command) |
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 | Method and Description |
---|---|
InvocationContext |
InvocationContextFactory.createRemoteInvocationContextForCommand(VisitableCommand cacheCommand,
Address origin)
As
InvocationContextFactory.createRemoteInvocationContext(org.infinispan.remoting.transport.Address) ,
but returning the flags to the context from the Command if any Flag was set. |
Modifier and Type | Method and Description |
---|---|
InvocationContext |
AbstractInvocationContextFactory.createRemoteInvocationContextForCommand(VisitableCommand cacheCommand,
Address origin) |
Modifier and Type | Method and Description |
---|---|
static Object |
StatsEnvelope.unpack(InvocationContext ctx,
VisitableCommand command,
Object o) |
static Object |
StatsEnvelope.unpackCollection(InvocationContext ctx,
VisitableCommand command,
Object o) |
static Object |
StatsEnvelope.unpackStream(InvocationContext ctx,
VisitableCommand command,
Object o) |
Modifier and Type | Interface and Description |
---|---|
interface |
InvocationCallback<C extends VisitableCommand>
Base interface for all callbacks used by
BaseAsyncInterceptor and InvocationStage methods. |
interface |
InvocationExceptionFunction<C extends VisitableCommand>
|
interface |
InvocationFinallyAction<C extends VisitableCommand>
|
interface |
InvocationFinallyFunction<C extends VisitableCommand>
|
interface |
InvocationSuccessAction<C extends VisitableCommand>
|
interface |
InvocationSuccessFunction<C extends VisitableCommand>
|
Modifier and Type | Method and Description |
---|---|
abstract <C extends VisitableCommand> |
InvocationStage.addCallback(InvocationContext ctx,
C command,
InvocationCallback<C> function)
After the current stage completes, invoke
function and return its result. |
<C extends VisitableCommand> |
SyncInvocationStage.addCallback(InvocationContext ctx,
C command,
InvocationCallback<C> function) |
<C extends VisitableCommand> |
InvocationStage.andExceptionally(InvocationContext ctx,
C command,
InvocationExceptionFunction<C> function)
After the current stage completes exceptionally, invoke
function and return its result. |
<C extends VisitableCommand> |
SyncInvocationStage.andExceptionally(InvocationContext ctx,
C command,
InvocationExceptionFunction<C> function) |
<C extends VisitableCommand> |
InvocationStage.andExceptionallyMakeStage(InvocationContext ctx,
C command,
InvocationExceptionFunction<C> function)
After the current stage completes exceptionally, invoke
function and return its result. |
<C extends VisitableCommand> |
SyncInvocationStage.andExceptionallyMakeStage(InvocationContext ctx,
C command,
InvocationExceptionFunction<C> function) |
<C extends VisitableCommand> |
InvocationStage.andFinally(InvocationContext ctx,
C command,
InvocationFinallyAction<C> action)
After the current stage completes, invoke
action . |
<C extends VisitableCommand> |
SyncInvocationStage.andFinally(InvocationContext ctx,
C command,
InvocationFinallyAction<C> action) |
<C extends VisitableCommand> |
InvocationStage.andFinallyMakeStage(InvocationContext ctx,
C command,
InvocationFinallyAction<C> action)
After the current stage completes, invoke
action . |
<C extends VisitableCommand> |
SyncInvocationStage.andFinallyMakeStage(InvocationContext ctx,
C command,
InvocationFinallyAction<C> action) |
<C extends VisitableCommand> |
InvocationStage.andHandle(InvocationContext ctx,
C command,
InvocationFinallyFunction<C> function)
After the current stage completes, invoke
function and return its result. |
<C extends VisitableCommand> |
SyncInvocationStage.andHandle(InvocationContext ctx,
C command,
InvocationFinallyFunction<C> function) |
<C extends VisitableCommand> |
InvocationStage.andHandleMakeStage(InvocationContext ctx,
C command,
InvocationFinallyFunction<C> function)
After the current stage completes, invoke
function and return its result. |
<C extends VisitableCommand> |
SyncInvocationStage.andHandleMakeStage(InvocationContext ctx,
C command,
InvocationFinallyFunction<C> function) |
<C extends VisitableCommand> |
BaseAsyncInterceptor.invokeNextAndExceptionally(InvocationContext ctx,
C command,
InvocationExceptionFunction<C> function)
Invoke the next interceptor, possibly with a new command, and execute an
InvocationCallback
after all the interceptors have finished with an exception. |
<C extends VisitableCommand> |
BaseAsyncInterceptor.invokeNextAndFinally(InvocationContext ctx,
C command,
InvocationFinallyAction<C> action)
Invoke the next interceptor, possibly with a new command, and execute an
InvocationCallback
after all the interceptors have finished, with or without an exception. |
<C extends VisitableCommand> |
BaseAsyncInterceptor.invokeNextAndHandle(InvocationContext ctx,
C command,
InvocationFinallyFunction<C> function)
Invoke the next interceptor, possibly with a new command, and execute an
InvocationCallback
after all the interceptors have finished, with or without an exception. |
<C extends VisitableCommand> |
BaseAsyncInterceptor.invokeNextThenAccept(InvocationContext ctx,
C command,
InvocationSuccessAction<C> action)
Invoke the next interceptor, possibly with a new command, and execute an
InvocationCallback
after all the interceptors have finished successfully. |
<C extends VisitableCommand> |
BaseAsyncInterceptor.invokeNextThenApply(InvocationContext ctx,
C command,
InvocationSuccessFunction<C> function)
Invoke the next interceptor, possibly with a new command, and execute an
InvocationCallback
after all the interceptors have finished successfully. |
<C extends VisitableCommand> |
InvocationStage.thenAccept(InvocationContext ctx,
C command,
InvocationSuccessAction<C> action)
After the current stage completes successfully, invoke
action . |
<C extends VisitableCommand> |
SyncInvocationStage.thenAccept(InvocationContext ctx,
C command,
InvocationSuccessAction<C> action) |
<C extends VisitableCommand> |
InvocationStage.thenAcceptMakeStage(InvocationContext ctx,
C command,
InvocationSuccessAction<C> action)
After the current stage completes successfully, invoke
action . |
<C extends VisitableCommand> |
SyncInvocationStage.thenAcceptMakeStage(InvocationContext ctx,
C command,
InvocationSuccessAction<C> action) |
<C extends VisitableCommand> |
InvocationStage.thenApply(InvocationContext ctx,
C command,
InvocationSuccessFunction<C> function)
After the current stage completes successfully, invoke
function and return its result. |
<C extends VisitableCommand> |
SyncInvocationStage.thenApply(InvocationContext ctx,
C command,
InvocationSuccessFunction<C> function) |
<C extends VisitableCommand> |
InvocationStage.thenApplyMakeStage(InvocationContext ctx,
C command,
InvocationSuccessFunction<C> function)
After the current stage completes successfully, invoke
function and return its result. |
<C extends VisitableCommand> |
SyncInvocationStage.thenApplyMakeStage(InvocationContext ctx,
C command,
InvocationSuccessFunction<C> function)
After the current stage completes successfully, invoke
function and return its result. |
Modifier and Type | Method and Description |
---|---|
Object |
ExceptionSyncInvocationStage.addCallback(InvocationContext ctx,
VisitableCommand command,
InvocationCallback function) |
Object |
ExceptionSyncInvocationStage.andExceptionally(InvocationContext ctx,
VisitableCommand command,
InvocationExceptionFunction function) |
Object |
ExceptionSyncInvocationStage.andFinally(InvocationContext ctx,
VisitableCommand command,
InvocationFinallyAction action) |
Object |
ExceptionSyncInvocationStage.andHandle(InvocationContext ctx,
VisitableCommand command,
InvocationFinallyFunction function) |
Object |
BaseAsyncInterceptor.asyncInvokeNext(InvocationContext ctx,
VisitableCommand command,
Collection<? extends CompletionStage<?>> delays)
Suspend invocation until all
delays complete, then if successful invoke the next interceptor. |
Object |
BaseAsyncInterceptor.asyncInvokeNext(InvocationContext ctx,
VisitableCommand command,
CompletionStage<?> delay)
Suspend the invocation until
delay completes, then if successful invoke the next interceptor. |
Object |
BaseAsyncInterceptor.asyncInvokeNext(InvocationContext ctx,
VisitableCommand command,
InvocationStage invocationStage)
Suspend the invocation until
invocationStage completes, then if successful invoke the next interceptor. |
protected Object |
DDAsyncInterceptor.handleDefault(InvocationContext ctx,
VisitableCommand command) |
Object |
AsyncInterceptorChain.invoke(InvocationContext ctx,
VisitableCommand command)
Walks the command through the interceptor chain.
|
Object |
EmptyAsyncInterceptorChain.invoke(InvocationContext ctx,
VisitableCommand command) |
CompletableFuture<Object> |
AsyncInterceptorChain.invokeAsync(InvocationContext ctx,
VisitableCommand command)
Walks the command through the interceptor chain.
|
CompletableFuture<Object> |
EmptyAsyncInterceptorChain.invokeAsync(InvocationContext ctx,
VisitableCommand command) |
Object |
BaseAsyncInterceptor.invokeNext(InvocationContext ctx,
VisitableCommand command)
Invoke the next interceptor, possibly with a new command.
|
Object |
ExceptionSyncInvocationStage.thenAccept(InvocationContext ctx,
VisitableCommand command,
InvocationSuccessAction function) |
Object |
ExceptionSyncInvocationStage.thenApply(InvocationContext ctx,
VisitableCommand command,
InvocationSuccessFunction function) |
Object |
ExceptionSyncInvocationStage.thenReturn(InvocationContext ctx,
VisitableCommand command,
Object returnValue) |
Object |
InvocationStage.thenReturn(InvocationContext ctx,
VisitableCommand command,
Object returnValue)
Overrides the return value of this
InvocationStage if it is completed successfully. |
Object |
SyncInvocationStage.thenReturn(InvocationContext ctx,
VisitableCommand command,
Object returnValue) |
Object |
AsyncInterceptor.visitCommand(InvocationContext ctx,
VisitableCommand command)
Perform some work for a command invocation.
|
Object |
DDAsyncInterceptor.visitCommand(InvocationContext ctx,
VisitableCommand command) |
Object |
DDAsyncInterceptor.visitUnknownCommand(InvocationContext ctx,
VisitableCommand command) |
Modifier and Type | Interface and Description |
---|---|
protected static interface |
BaseDistributionInterceptor.ReadManyCommandHelper<C extends VisitableCommand> |
Modifier and Type | Method and Description |
---|---|
protected <C extends VisitableCommand & FlagAffectedCommand & TopologyAffectedCommand,K> |
TxDistributionInterceptor.handleTxWriteManyCommand(InvocationContext ctx,
C command,
Collection<K> keys,
BiFunction<C,List<K>,C> copyCommand) |
Modifier and Type | Method and Description |
---|---|
Object |
ScatteredDistributionInterceptor.PrimaryResponseHandler.apply(InvocationContext rCtx,
VisitableCommand rCommand,
Object rv) |
Modifier and Type | Method and Description |
---|---|
<C extends VisitableCommand> |
SimpleAsyncInvocationStage.addCallback(InvocationContext ctx,
C command,
InvocationCallback<C> function) |
protected <C extends VisitableCommand & TopologyAffectedCommand & FlagAffectedCommand> |
BaseStateTransferInterceptor.handleReadCommand(InvocationContext ctx,
C command) |
protected <T extends VisitableCommand> |
BaseStateTransferInterceptor.retryWhenDone(CompletableFuture<Void> future,
int topologyId,
InvocationContext ctx,
T command,
InvocationFinallyFunction<T> callback) |
Modifier and Type | Method and Description |
---|---|
static Object |
MultiSubCommandInvoker.invokeEach(InvocationContext ctx,
Iterator<VisitableCommand> subCommands,
BaseAsyncInterceptor interceptor,
Object finalReturnValue)
Call
BaseAsyncInterceptor.invokeNext(InvocationContext, VisitableCommand) on a sequence of sub-commands. |
Constructor and Description |
---|
QueueAsyncInvocationStage(InvocationContext ctx,
VisitableCommand command,
CompletableFuture<?> valueFuture,
InvocationCallback function) |
Modifier and Type | Method and Description |
---|---|
protected InvocationStage |
AbstractLockingInterceptor.lockAndRecord(InvocationContext context,
VisitableCommand command,
Object key,
long timeout) |
Modifier and Type | Method and Description |
---|---|
protected void |
PartitionHandlingInterceptor.postTxCommandCheck(InvocationContext rCtx,
VisitableCommand rCommand,
Object rv) |
Modifier and Type | Method and Description |
---|---|
Object |
StateTransferInterceptor.handleDefault(InvocationContext ctx,
VisitableCommand command) |
Object |
TransactionSynchronizerInterceptor.visitCommand(InvocationContext ctx,
VisitableCommand command) |
Modifier and Type | Method and Description |
---|---|
CompletionStage<Void> |
BackupReceiver.handleRemoteCommand(VisitableCommand command,
boolean preserveOrder) |
CompletionStage<Void> |
ClusteredCacheBackupReceiver.handleRemoteCommand(VisitableCommand command,
boolean preserveOrder) |
Constructor and Description |
---|
SingleXSiteRpcCommand(ByteString cacheName,
VisitableCommand command) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.