Package | Description |
---|---|
org.infinispan.commands |
Commands that operate on the cache, either locally or remotely.
|
org.infinispan.commands.functional | |
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.impl |
This package contains different context implementations, selected dynamically based on the type of invocation.
|
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.interceptors.xsite |
Interceptors dealing with cross-site replication.
|
org.infinispan.partitionhandling.impl | |
org.infinispan.persistence.manager |
Implementations of the
PersistenceManager interface, which define the logic
of how infinispan interacts with external stores. |
org.infinispan.persistence.support | |
org.infinispan.statetransfer |
Transfer of state to new caches in a cluster.
|
org.infinispan.transaction.impl | |
org.infinispan.transaction.xa |
XA transaction support.
|
org.infinispan.transaction.xa.recovery | |
org.infinispan.xsite | |
org.infinispan.xsite.irac |
Modifier and Type | Method and Description |
---|---|
PrepareCommand |
CommandsFactory.buildPrepareCommand(GlobalTransaction gtx,
List<WriteCommand> modifications,
boolean onePhaseCommit)
Builds a PrepareCommand
|
PrepareCommand |
CommandsFactoryImpl.buildPrepareCommand(GlobalTransaction gtx,
List<WriteCommand> modifications,
boolean onePhaseCommit) |
VersionedPrepareCommand |
CommandsFactory.buildVersionedPrepareCommand(GlobalTransaction gtx,
List<WriteCommand> modifications,
boolean onePhase)
Builds a VersionedPrepareCommand
|
VersionedPrepareCommand |
CommandsFactoryImpl.buildVersionedPrepareCommand(GlobalTransaction gtx,
List<WriteCommand> modifications,
boolean onePhase) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractWriteKeyCommand<K,V> |
class |
AbstractWriteManyCommand<K,V> |
class |
ReadWriteKeyCommand<K,V,R> |
class |
ReadWriteKeyValueCommand<K,V,T,R> |
class |
ReadWriteManyCommand<K,V,R> |
class |
ReadWriteManyEntriesCommand<K,V,T,R> |
class |
WriteOnlyKeyCommand<K,V> |
class |
WriteOnlyKeyValueCommand<K,V,T> |
class |
WriteOnlyManyCommand<K,V> |
class |
WriteOnlyManyEntriesCommand<K,V,T> |
Modifier and Type | Field and Description |
---|---|
protected WriteCommand[] |
PrepareCommand.modifications |
Modifier and Type | Method and Description |
---|---|
WriteCommand[] |
PrepareCommand.getModifications() |
Constructor and Description |
---|
PrepareCommand(ByteString cacheName,
GlobalTransaction gtx,
boolean onePhaseCommit,
WriteCommand... modifications) |
Constructor and Description |
---|
PrepareCommand(ByteString cacheName,
GlobalTransaction gtx,
List<WriteCommand> commands,
boolean onePhaseCommit) |
VersionedPrepareCommand(ByteString cacheName,
GlobalTransaction gtx,
List<WriteCommand> modifications,
boolean onePhase) |
Modifier and Type | Interface and Description |
---|---|
interface |
DataWriteCommand
Mixes features from DataCommand and WriteCommand
|
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 |
---|---|
List<WriteCommand> |
AbstractTxInvocationContext.getModifications() |
List<WriteCommand> |
TxInvocationContext.getModifications()
Returns the modifications performed in the scope of the current transaction.
|
Modifier and Type | Method and Description |
---|---|
protected <C extends WriteCommand> |
BiasedScatteredDistributionInterceptor.createMultiTargetCollector(C command,
int primaries) |
protected <C extends WriteCommand> |
ScatteredDistributionInterceptor.createMultiTargetCollector(C command,
int primaries) |
Modifier and Type | Method and Description |
---|---|
protected void |
BiasedScatteredDistributionInterceptor.completeManyWriteOnPrimaryOriginator(WriteCommand command,
Address backup,
org.infinispan.interceptors.distribution.CountDownCompletableFuture future) |
protected void |
ScatteredDistributionInterceptor.completeManyWriteOnPrimaryOriginator(WriteCommand command,
Address backup,
org.infinispan.interceptors.distribution.CountDownCompletableFuture future)
This is a hook for bias-enabled mode where the primary performs additional RPCs but replication to another node.
|
protected void |
BaseDistributionInterceptor.handleRemotelyRetrievedKeys(InvocationContext ctx,
WriteCommand appliedCommand,
List<?> remoteKeys) |
protected void |
TxDistributionInterceptor.handleRemotelyRetrievedKeys(InvocationContext ctx,
WriteCommand appliedCommand,
List<?> remoteKeys) |
protected CompletionStage<ValidResponse> |
BiasedScatteredDistributionInterceptor.manyWriteOnRemotePrimary(Address target,
WriteCommand command,
CommandAckCollector.MultiTargetCollector multiTargetCollector) |
protected CompletionStage<ValidResponse> |
ScatteredDistributionInterceptor.manyWriteOnRemotePrimary(Address target,
WriteCommand command,
CommandAckCollector.MultiTargetCollector multiTargetCollector) |
protected Object |
BiasedScatteredDistributionInterceptor.manyWriteResponse(InvocationContext ctx,
WriteCommand cmd,
Object returnValue) |
protected Object |
ScatteredDistributionInterceptor.manyWriteResponse(InvocationContext ctx,
WriteCommand cmd,
Object returnValue) |
Modifier and Type | Method and Description |
---|---|
protected int |
AbstractIracLocalSiteInterceptor.getSegment(WriteCommand command,
Object key) |
protected Object |
PrefetchInterceptor.handleWriteManyCommand(InvocationContext ctx,
WriteCommand command) |
protected boolean |
CacheLoaderInterceptor.isConditional(WriteCommand cmd) |
protected static boolean |
AbstractIracLocalSiteInterceptor.isNormalWriteCommand(WriteCommand command) |
protected Object |
RetryingEntryWrappingInterceptor.setSkipRemoteGetsAndInvokeNextForManyEntriesCommand(InvocationContext ctx,
WriteCommand command,
CompletionStage<Void> delay) |
protected Object |
BiasedEntryWrappingInterceptor.setSkipRemoteGetsAndInvokeNextForManyEntriesCommand(InvocationContext ctx,
WriteCommand command,
CompletionStage<Void> delay) |
protected Object |
EntryWrappingInterceptor.setSkipRemoteGetsAndInvokeNextForManyEntriesCommand(InvocationContext ctx,
WriteCommand command,
CompletionStage<Void> delay)
Locks the value for the keys accessed by the command to avoid being override from a remote get.
|
protected boolean |
CacheLoaderInterceptor.skipLoadForWriteCommand(WriteCommand cmd,
Object key,
InvocationContext ctx) |
protected boolean |
ClusteredCacheLoaderInterceptor.skipLoadForWriteCommand(WriteCommand cmd,
Object key,
InvocationContext ctx) |
protected Stream<org.infinispan.interceptors.impl.AbstractIracLocalSiteInterceptor.StreamData> |
AbstractIracLocalSiteInterceptor.streamKeysFromCommand(WriteCommand command) |
protected Stream<org.infinispan.interceptors.impl.AbstractIracLocalSiteInterceptor.StreamData> |
AbstractIracLocalSiteInterceptor.streamKeysFromModifications(WriteCommand[] mods) |
Modifier and Type | Method and Description |
---|---|
protected Stream<org.infinispan.interceptors.impl.AbstractIracLocalSiteInterceptor.StreamData> |
AbstractIracLocalSiteInterceptor.streamKeysFromModifications(Stream<WriteCommand> modsStream) |
Modifier and Type | Method and Description |
---|---|
protected abstract <K> Object |
AbstractLockingInterceptor.handleWriteManyCommand(InvocationContext ctx,
WriteCommand command,
Collection<K> keys,
boolean forwarded) |
protected <K> Object |
NonTransactionalLockingInterceptor.handleWriteManyCommand(InvocationContext ctx,
WriteCommand command,
Collection<K> keys,
boolean forwarded) |
protected <K> Object |
OptimisticLockingInterceptor.handleWriteManyCommand(InvocationContext ctx,
WriteCommand command,
Collection<K> keys,
boolean forwarded) |
protected <K> Object |
PessimisticLockingInterceptor.handleWriteManyCommand(InvocationContext ctx,
WriteCommand command,
Collection<K> keys,
boolean forwarded) |
Modifier and Type | Method and Description |
---|---|
protected Stream<WriteCommand> |
BaseBackupInterceptor.getModificationsFrom(CommitCommand cmd) |
Modifier and Type | Method and Description |
---|---|
boolean |
AvailablePartitionHandlingManager.addPartialCommit1PCTransaction(GlobalTransaction globalTransaction,
Collection<Address> affectedNodes,
Collection<Object> lockedKeys,
List<WriteCommand> modifications) |
boolean |
PartitionHandlingManager.addPartialCommit1PCTransaction(GlobalTransaction globalTransaction,
Collection<Address> affectedNodes,
Collection<Object> lockedKeys,
List<WriteCommand> modifications)
Adds a partially committed transaction.
|
boolean |
PartitionHandlingManagerImpl.addPartialCommit1PCTransaction(GlobalTransaction globalTransaction,
Collection<Address> affectedNodes,
Collection<Object> lockedKeys,
List<WriteCommand> modifications) |
Modifier and Type | Method and Description |
---|---|
CompletionStage<Long> |
PersistenceManager.performBatch(TxInvocationContext<AbstractCacheTransaction> invocationContext,
BiPredicate<? super WriteCommand,Object> commandKeyPredicate)
Writes a batch for the given modifications in the transactional context
|
CompletionStage<Long> |
PersistenceManagerImpl.performBatch(TxInvocationContext<AbstractCacheTransaction> ctx,
BiPredicate<? super WriteCommand,Object> commandKeyPredicate) |
CompletionStage<Long> |
PersistenceManagerStub.performBatch(TxInvocationContext<AbstractCacheTransaction> invocationContext,
BiPredicate<? super WriteCommand,Object> commandKeyPredicate) |
Modifier and Type | Method and Description |
---|---|
CompletionStage<Long> |
DelegatingPersistenceManager.performBatch(TxInvocationContext<AbstractCacheTransaction> invocationContext,
BiPredicate<? super WriteCommand,Object> commandKeyPredicate) |
Modifier and Type | Method and Description |
---|---|
WriteCommand[] |
TransactionInfo.getModifications() |
Constructor and Description |
---|
TransactionInfo(GlobalTransaction globalTransaction,
int topologyId,
WriteCommand[] modifications,
Set<Object> lockedKeys) |
Modifier and Type | Field and Description |
---|---|
protected List<WriteCommand> |
AbstractCacheTransaction.modifications |
Modifier and Type | Method and Description |
---|---|
List<WriteCommand> |
AbstractCacheTransaction.getAllModifications() |
List<WriteCommand> |
AbstractCacheTransaction.getModifications() |
Modifier and Type | Method and Description |
---|---|
void |
LocalTransaction.addModification(WriteCommand mod) |
RemoteTransaction |
TransactionTable.getOrCreateRemoteTransaction(GlobalTransaction globalTx,
WriteCommand[] modifications)
Returns an existing remote transaction or creates one if none exists.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractCacheTransaction.setModifications(List<WriteCommand> modifications) |
Constructor and Description |
---|
RemoteTransaction(WriteCommand[] modifications,
GlobalTransaction tx,
int topologyId,
long txCreationTime) |
Modifier and Type | Method and Description |
---|---|
List<WriteCommand> |
CacheTransaction.getAllModifications()
Returns all the modifications visible within the current transaction, including those using Flag#CACHE_MODE_LOCAL.
|
List<WriteCommand> |
CacheTransaction.getModifications()
Returns the modifications visible within the current transaction.
|
Modifier and Type | Method and Description |
---|---|
RemoteTransaction |
TransactionFactory.newRemoteTransaction(WriteCommand[] modifications,
GlobalTransaction tx,
int topologyId) |
abstract RemoteTransaction |
TransactionFactory.TxFactoryEnum.newRemoteTransaction(WriteCommand[] modifications,
GlobalTransaction tx,
int topologyId,
long txCreationTime) |
Constructor and Description |
---|
RecoveryAwareRemoteTransaction(WriteCommand[] modifications,
GlobalTransaction tx,
int topologyId,
long txCreationTime) |
Modifier and Type | Method and Description |
---|---|
InvocationStage |
BackupSender.backupWrite(WriteCommand command,
WriteCommand originalCommand) |
InvocationStage |
BackupSenderImpl.backupWrite(WriteCommand command,
WriteCommand originalCommand) |
InvocationStage |
NoOpBackupSender.backupWrite(WriteCommand command,
WriteCommand originalCommand) |
Modifier and Type | Method and Description |
---|---|
Stream<?> |
DefaultIracManager.keysFromMods(Stream<WriteCommand> modifications) |
void |
DefaultIracManager.trackKeysFromTransaction(Stream<WriteCommand> modifications,
GlobalTransaction lockOwner) |
void |
IracManager.trackKeysFromTransaction(Stream<WriteCommand> modifications,
GlobalTransaction lockOwner)
Sets all keys affected by the transaction as changed.
|
void |
NoOpIracManager.trackKeysFromTransaction(Stream<WriteCommand> modifications,
GlobalTransaction lockOwner) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.