| Package | Description |
|---|---|
| org.infinispan.commands.functional | |
| org.infinispan.commands.write |
Commands that alter the state of the cache.
|
| 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 |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractWriteKeyCommand<K,V> |
class |
ReadWriteKeyCommand<K,V,R> |
class |
ReadWriteKeyValueCommand<K,V,T,R> |
class |
WriteOnlyKeyCommand<K,V> |
class |
WriteOnlyKeyValueCommand<K,V,T> |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractDataWriteCommand
Stuff common to WriteCommands
|
class |
ComputeCommand |
class |
ComputeIfAbsentCommand |
class |
EvictCommand |
class |
PutKeyValueCommand
Implements functionality defined by
BasicCache.put(Object, Object) |
class |
RemoveCommand |
class |
RemoveExpiredCommand
Removes an entry that is expired from memory
|
class |
ReplaceCommand |
| Modifier and Type | Method and Description |
|---|---|
protected CompletionStage<?> |
BiasedScatteredDistributionInterceptor.completeSingleWriteOnPrimaryOriginator(DataWriteCommand command,
Address backup,
CompletionStage<?> rpcFuture) |
protected CompletionStage<?> |
ScatteredDistributionInterceptor.completeSingleWriteOnPrimaryOriginator(DataWriteCommand command,
Address backup,
CompletionStage<?> rpcFuture)
This is a hook for bias-enabled mode where the primary performs additional RPCs but replication to another node.
|
protected Object |
BaseDistributionInterceptor.invokeRemotely(InvocationContext ctx,
DataWriteCommand command,
Address primaryOwner) |
protected CompletionStage<ValidResponse> |
BiasedScatteredDistributionInterceptor.singleWriteOnRemotePrimary(Address target,
DataWriteCommand command) |
protected CompletionStage<ValidResponse> |
ScatteredDistributionInterceptor.singleWriteOnRemotePrimary(Address target,
DataWriteCommand command)
This method is called by a non-owner sending write request to the primary owner
|
protected Object |
BiasedScatteredDistributionInterceptor.singleWriteResponse(InvocationContext ctx,
DataWriteCommand cmd,
Object returnValue) |
protected Object |
ScatteredDistributionInterceptor.singleWriteResponse(InvocationContext ctx,
DataWriteCommand cmd,
Object returnValue)
This method is called by primary owner responding to the originator after write has been completed
|
Object |
L1LastChanceInterceptor.visitDataWriteCommand(InvocationContext ctx,
DataWriteCommand command,
boolean assumeOriginKeptEntryInL1) |
| Modifier and Type | Method and Description |
|---|---|
protected Object |
PrefetchInterceptor.handleWriteCommand(InvocationContext ctx,
DataWriteCommand command) |
protected void |
AbstractIracRemoteSiteInterceptor.setIracMetadataForOwner(InvocationContext ctx,
DataWriteCommand command,
Object rv)
Invoked by backup owners, it make sure the entry has the same version as set by the primary owner.
|
protected Object |
RetryingEntryWrappingInterceptor.setSkipRemoteGetsAndInvokeNextForDataCommand(InvocationContext ctx,
DataWriteCommand command,
CompletionStage<Void> delay) |
protected Object |
BiasedEntryWrappingInterceptor.setSkipRemoteGetsAndInvokeNextForDataCommand(InvocationContext ctx,
DataWriteCommand command,
CompletionStage<Void> delay) |
protected Object |
EntryWrappingInterceptor.setSkipRemoteGetsAndInvokeNextForDataCommand(InvocationContext ctx,
DataWriteCommand command,
CompletionStage<Void> delay)
Locks the value for the keys accessed by the command to avoid being override from a remote get.
|
protected void |
AbstractIracRemoteSiteInterceptor.validateOnPrimary(InvocationContext ctx,
DataWriteCommand command,
Object rv)
Invoked on the primary owner, it validates if the remote site update is valid or not.
|
| Modifier and Type | Method and Description |
|---|---|
protected abstract Object |
AbstractLockingInterceptor.visitDataWriteCommand(InvocationContext ctx,
DataWriteCommand command) |
protected Object |
NonTransactionalLockingInterceptor.visitDataWriteCommand(InvocationContext ctx,
DataWriteCommand command) |
protected Object |
OptimisticLockingInterceptor.visitDataWriteCommand(InvocationContext ctx,
DataWriteCommand command) |
protected Object |
PessimisticLockingInterceptor.visitDataWriteCommand(InvocationContext ctx,
DataWriteCommand command) |
| Modifier and Type | Method and Description |
|---|---|
protected Object |
PartitionHandlingInterceptor.handleSingleWrite(InvocationContext ctx,
DataWriteCommand command) |
Copyright © 2022 JBoss by Red Hat. All rights reserved.