| 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.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.eviction |
Classes related to eviction.
|
| org.infinispan.eviction.impl | |
| 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.notifications.cachelistener |
Cache-specific notifications and eventing. |
| org.infinispan.persistence.util |
| Modifier and Type | Method and Description |
|---|---|
static <K,V> Cache<K,V> |
Caches.getCacheWithFlags(Cache<K,V> cache,
FlagAffectedCommand command) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
DataCommand
Commands of this type manipulate data in the cache.
|
| 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 |
|---|---|
protected boolean |
AbstractFlagAffectedCommand.hasSameFlags(FlagAffectedCommand other) |
| 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. |
| 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 |
|---|---|
static Flag |
FlagBitSets.extractStateTransferFlag(InvocationContext ctx,
FlagAffectedCommand command) |
| Modifier and Type | Method and Description |
|---|---|
CompletionStage<Void> |
EvictionManager.onEntryEviction(Map<K,Map.Entry<K,V>> evicted,
FlagAffectedCommand command)
Handles notifications of evicted entries based on if the command allow them
|
| Modifier and Type | Method and Description |
|---|---|
CompletionStage<Void> |
EvictionManagerImpl.onEntryEviction(Map<K,Map.Entry<K,V>> evicted,
FlagAffectedCommand command) |
| Modifier and Type | Field and Description |
|---|---|
protected FlagAffectedCommand |
DistributionBulkInterceptor.BackingEntrySet.command |
protected FlagAffectedCommand |
DistributionBulkInterceptor.BackingKeySet.command |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
BaseDistributionInterceptor.readNeedsRemoteValue(FlagAffectedCommand command) |
protected boolean |
L1TxInterceptor.skipL1Lookup(FlagAffectedCommand command,
Object key) |
protected boolean |
L1NonTxInterceptor.skipL1Lookup(FlagAffectedCommand command,
Object key) |
| Constructor and Description |
|---|
BackingKeySet(Cache<K,V> cache,
CacheSet<K> keySet,
FlagAffectedCommand 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 CompletionStage<Void> |
EntryWrappingInterceptor.commitContextEntries(InvocationContext ctx,
FlagAffectedCommand command) |
protected CompletionStage<Void> |
VersionedEntryWrappingInterceptor.commitContextEntry(CacheEntry<?,?> entry,
InvocationContext ctx,
FlagAffectedCommand command,
Flag stateTransferFlag,
boolean l1Invalidation) |
protected CompletionStage<Void> |
EntryWrappingInterceptor.commitContextEntry(CacheEntry<?,?> entry,
InvocationContext ctx,
FlagAffectedCommand command,
Flag stateTransferFlag,
boolean l1Invalidation) |
AdvancedCache |
PrefetchInterceptor.getCacheWithFlags(FlagAffectedCommand command) |
protected boolean |
CacheLoaderInterceptor.hasSkipLoadFlag(FlagAffectedCommand cmd) |
protected static boolean |
AbstractIracLocalSiteInterceptor.isIracState(FlagAffectedCommand command) |
protected boolean |
BaseRpcInterceptor.isLocalModeForced(FlagAffectedCommand command) |
protected boolean |
CacheWriterInterceptor.isProperWriter(InvocationContext ctx,
FlagAffectedCommand command,
Object key) |
protected boolean |
DistCacheWriterInterceptor.isProperWriter(InvocationContext ctx,
FlagAffectedCommand command,
Object key) |
protected boolean |
CacheWriterInterceptor.isStoreEnabled(FlagAffectedCommand command) |
protected boolean |
PassivationWriterInterceptor.isStoreEnabled(FlagAffectedCommand command) |
protected boolean |
BaseRpcInterceptor.isSynchronous(FlagAffectedCommand command) |
CompletionStage<InternalCacheEntry<K,V>> |
CacheLoaderInterceptor.loadAndStoreInDataContainer(InvocationContext ctx,
Object key,
int segment,
FlagAffectedCommand cmd) |
CompletionStage<InternalCacheEntry<K,V>> |
PassivationCacheLoaderInterceptor.loadAndStoreInDataContainer(InvocationContext ctx,
Object key,
int segment,
FlagAffectedCommand cmd) |
CompletionStage<InternalCacheEntry<K,V>> |
PassivationClusteredCacheLoaderInterceptor.loadAndStoreInDataContainer(InvocationContext ctx,
Object key,
int segment,
FlagAffectedCommand cmd) |
protected CompletionStage<Void> |
CacheLoaderInterceptor.loadIfNeeded(InvocationContext ctx,
Object key,
FlagAffectedCommand cmd)
Loads from the cache loader the entry for the given key.
|
protected CompletionStage<Void> |
CacheLoaderInterceptor.loadInContext(InvocationContext ctx,
Object key,
FlagAffectedCommand cmd)
Attemps to load the given entry for a key from the persistence store.
|
protected CompletionStage<Void> |
CacheLoaderInterceptor.sendNotification(Object key,
Object value,
boolean pre,
InvocationContext ctx,
FlagAffectedCommand cmd) |
protected boolean |
ScatteredCacheWriterInterceptor.skipSharedStores(InvocationContext ctx,
Object key,
FlagAffectedCommand command) |
protected boolean |
CacheWriterInterceptor.skipSharedStores(InvocationContext ctx,
Object key,
FlagAffectedCommand command) |
protected boolean |
DistCacheWriterInterceptor.skipSharedStores(InvocationContext ctx,
Object key,
FlagAffectedCommand command) |
| Modifier and Type | Method and Description |
|---|---|
protected ClusteringDependentLogic.Commit |
ClusteringDependentLogic.AbstractClusteringDependentLogic.clusterCommitType(FlagAffectedCommand command,
InvocationContext ctx,
int segment,
boolean removed) |
CompletionStage<Void> |
ClusteringDependentLogic.commitEntry(CacheEntry entry,
FlagAffectedCommand command,
InvocationContext ctx,
Flag trackFlag,
boolean l1Invalidation)
Commits the entry to the data container.
|
CompletionStage<Void> |
ClusteringDependentLogic.AbstractClusteringDependentLogic.commitEntry(CacheEntry entry,
FlagAffectedCommand command,
InvocationContext ctx,
Flag trackFlag,
boolean l1Invalidation) |
CompletionStage<Void> |
OrderedClusteringDependentLogic.commitEntry(CacheEntry entry,
FlagAffectedCommand command,
InvocationContext ctx,
Flag trackFlag,
boolean l1Invalidation) |
protected abstract CompletionStage<Void> |
ClusteringDependentLogic.AbstractClusteringDependentLogic.commitSingleEntry(CacheEntry entry,
FlagAffectedCommand command,
InvocationContext ctx,
Flag trackFlag,
boolean l1Invalidation) |
protected CompletionStage<Void> |
ClusteringDependentLogic.LocalLogic.commitSingleEntry(CacheEntry entry,
FlagAffectedCommand command,
InvocationContext ctx,
Flag trackFlag,
boolean l1Invalidation) |
protected CompletionStage<Void> |
ClusteringDependentLogic.InvalidationLogic.commitSingleEntry(CacheEntry entry,
FlagAffectedCommand command,
InvocationContext ctx,
Flag trackFlag,
boolean l1Invalidation) |
protected CompletionStage<Void> |
ClusteringDependentLogic.ReplicationLogic.commitSingleEntry(CacheEntry entry,
FlagAffectedCommand command,
InvocationContext ctx,
Flag trackFlag,
boolean l1Invalidation) |
protected CompletionStage<Void> |
ClusteringDependentLogic.DistributionLogic.commitSingleEntry(CacheEntry entry,
FlagAffectedCommand command,
InvocationContext ctx,
Flag trackFlag,
boolean l1Invalidation) |
protected CompletableFuture<Void> |
ClusteringDependentLogic.ScatteredLogic.commitSingleEntry(CacheEntry entry,
FlagAffectedCommand command,
InvocationContext ctx,
Flag trackFlag,
boolean l1Invalidation) |
ClusteringDependentLogic.Commit |
ClusteringDependentLogic.commitType(FlagAffectedCommand command,
InvocationContext ctx,
int segment,
boolean removed)
Determines what type of commit this is.
|
ClusteringDependentLogic.Commit |
ClusteringDependentLogic.AbstractClusteringDependentLogic.commitType(FlagAffectedCommand command,
InvocationContext ctx,
int segment,
boolean removed) |
ClusteringDependentLogic.Commit |
ClusteringDependentLogic.LocalLogic.commitType(FlagAffectedCommand command,
InvocationContext ctx,
int segment,
boolean removed) |
ClusteringDependentLogic.Commit |
ClusteringDependentLogic.InvalidationLogic.commitType(FlagAffectedCommand command,
InvocationContext ctx,
int segment,
boolean removed) |
ClusteringDependentLogic.Commit |
ClusteringDependentLogic.ReplicationLogic.commitType(FlagAffectedCommand command,
InvocationContext ctx,
int segment,
boolean removed) |
ClusteringDependentLogic.Commit |
OrderedClusteringDependentLogic.commitType(FlagAffectedCommand command,
InvocationContext ctx,
int segment,
boolean removed) |
protected long |
AbstractLockingInterceptor.getLockTimeoutMillis(FlagAffectedCommand command) |
protected abstract Object |
AbstractLockingInterceptor.handleReadManyCommand(InvocationContext ctx,
FlagAffectedCommand command,
Collection<?> keys) |
protected Object |
AbstractTxLockingInterceptor.handleReadManyCommand(InvocationContext ctx,
FlagAffectedCommand command,
Collection<?> keys) |
protected Object |
NonTransactionalLockingInterceptor.handleReadManyCommand(InvocationContext ctx,
FlagAffectedCommand command,
Collection<?> keys) |
protected Object |
OptimisticLockingInterceptor.handleReadManyCommand(InvocationContext ctx,
FlagAffectedCommand command,
Collection<?> keys) |
protected Object |
PessimisticLockingInterceptor.handleReadManyCommand(InvocationContext ctx,
FlagAffectedCommand command,
Collection<?> keys) |
| Modifier and Type | Method and Description |
|---|---|
CompletionStage<InternalCacheEntry<K,V>> |
EntryLoader.loadAndStoreInDataContainer(InvocationContext ctx,
Object key,
int segment,
FlagAffectedCommand cmd)
Load and store the entry if present in the data container, returning the entry in the CompletionStage
|
Copyright © 2022 JBoss by Red Hat. All rights reserved.