Package | Description |
---|---|
org.infinispan.configuration.cache |
Cache configuration |
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.interceptors.xsite |
Interceptors dealing with cross-site replication.
|
org.infinispan.partitionhandling.impl | |
org.infinispan.security.actions | |
org.infinispan.statetransfer |
Transfer of state to new caches in a cluster.
|
Modifier and Type | Field and Description |
---|---|
static AttributeDefinition<AsyncInterceptor> |
InterceptorConfiguration.INTERCEPTOR |
Modifier and Type | Method and Description |
---|---|
AsyncInterceptor |
InterceptorConfiguration.asyncInterceptor() |
Modifier and Type | Method and Description |
---|---|
Class<? extends AsyncInterceptor> |
InterceptorConfiguration.after() |
Class<? extends AsyncInterceptor> |
InterceptorConfiguration.before() |
Class<? extends AsyncInterceptor> |
InterceptorConfiguration.sequentialInterceptorClass() |
Modifier and Type | Method and Description |
---|---|
InterceptorConfigurationBuilder |
InterceptorConfigurationBuilder.interceptor(AsyncInterceptor interceptor)
Deprecated.
An instance of the new custom interceptor to add to the configuration.
|
Modifier and Type | Method and Description |
---|---|
InterceptorConfigurationBuilder |
InterceptorConfigurationBuilder.after(Class<? extends AsyncInterceptor> after)
Deprecated.
Dictates that the custom interceptor appears immediately after the specified interceptor.
|
InterceptorConfigurationBuilder |
InterceptorConfigurationBuilder.before(Class<? extends AsyncInterceptor> before)
Deprecated.
Dictates that the custom interceptor appears immediately before the specified interceptor.
|
InterceptorConfigurationBuilder |
InterceptorConfigurationBuilder.interceptorClass(Class<? extends AsyncInterceptor> interceptorClass)
Deprecated.
Class of the new custom interceptor to add to the configuration.
|
Modifier and Type | Class and Description |
---|---|
class |
BaseAsyncInterceptor
Base class for an interceptor in the new asynchronous invocation chain.
|
class |
BaseCustomAsyncInterceptor
Anyone using the
AsyncInterceptorChain.addInterceptor(AsyncInterceptor, int) method (or any of its
overloaded forms) or registering custom interceptors via XML should extend this base class when creating their own
custom interceptors. |
class |
DDAsyncInterceptor
Interface for async interceptors using double-dispatch.
|
Modifier and Type | Method and Description |
---|---|
<T extends AsyncInterceptor> |
AsyncInterceptorChain.findInterceptorExtending(Class<T> interceptorClass)
Returns the first interceptor extending the given class, or
null if there is none. |
<T extends AsyncInterceptor> |
EmptyAsyncInterceptorChain.findInterceptorExtending(Class<T> interceptorClass) |
<T extends AsyncInterceptor> |
AsyncInterceptorChain.findInterceptorWithClass(Class<T> interceptorClass)
Returns the first interceptor with the given class, or
null if there is none. |
<T extends AsyncInterceptor> |
EmptyAsyncInterceptorChain.findInterceptorWithClass(Class<T> interceptorClass) |
Modifier and Type | Method and Description |
---|---|
List<AsyncInterceptor> |
AsyncInterceptorChain.getInterceptors() |
List<AsyncInterceptor> |
EmptyAsyncInterceptorChain.getInterceptors() |
Modifier and Type | Method and Description |
---|---|
void |
AsyncInterceptorChain.addInterceptor(AsyncInterceptor interceptor,
int position)
Inserts the given interceptor at the specified position in the chain (0 based indexing).
|
void |
EmptyAsyncInterceptorChain.addInterceptor(AsyncInterceptor interceptor,
int position) |
boolean |
AsyncInterceptorChain.addInterceptorAfter(AsyncInterceptor toAdd,
Class<? extends AsyncInterceptor> afterInterceptor)
Adds a new interceptor in list after an interceptor of a given type.
|
boolean |
EmptyAsyncInterceptorChain.addInterceptorAfter(AsyncInterceptor toAdd,
Class<? extends AsyncInterceptor> afterInterceptor) |
boolean |
AsyncInterceptorChain.addInterceptorBefore(AsyncInterceptor toAdd,
Class<? extends AsyncInterceptor> beforeInterceptor)
Adds a new interceptor in list before an interceptor of a given type.
|
boolean |
EmptyAsyncInterceptorChain.addInterceptorBefore(AsyncInterceptor toAdd,
Class<? extends AsyncInterceptor> beforeInterceptor) |
void |
AsyncInterceptorChain.appendInterceptor(AsyncInterceptor ci,
boolean isCustom)
Appends at the end.
|
void |
EmptyAsyncInterceptorChain.appendInterceptor(AsyncInterceptor ci,
boolean isCustom) |
boolean |
AsyncInterceptorChain.containsInstance(AsyncInterceptor interceptor)
Checks whether the chain contains the supplied interceptor instance.
|
boolean |
EmptyAsyncInterceptorChain.containsInstance(AsyncInterceptor interceptor) |
boolean |
AsyncInterceptorChain.replaceInterceptor(AsyncInterceptor replacingInterceptor,
Class<? extends AsyncInterceptor> toBeReplacedInterceptorType)
Replaces an existing interceptor of the given type in the interceptor chain with a new interceptor
instance passed as parameter.
|
boolean |
EmptyAsyncInterceptorChain.replaceInterceptor(AsyncInterceptor replacingInterceptor,
Class<? extends AsyncInterceptor> toBeReplacedInterceptorType) |
void |
AsyncInterceptor.setNextInterceptor(AsyncInterceptor interceptorStage)
Sets up the interceptor.
|
void |
BaseAsyncInterceptor.setNextInterceptor(AsyncInterceptor nextInterceptor)
Used internally to set up the interceptor.
|
Modifier and Type | Method and Description |
---|---|
boolean |
AsyncInterceptorChain.addInterceptorAfter(AsyncInterceptor toAdd,
Class<? extends AsyncInterceptor> afterInterceptor)
Adds a new interceptor in list after an interceptor of a given type.
|
boolean |
EmptyAsyncInterceptorChain.addInterceptorAfter(AsyncInterceptor toAdd,
Class<? extends AsyncInterceptor> afterInterceptor) |
boolean |
AsyncInterceptorChain.addInterceptorBefore(AsyncInterceptor toAdd,
Class<? extends AsyncInterceptor> beforeInterceptor)
Adds a new interceptor in list before an interceptor of a given type.
|
boolean |
EmptyAsyncInterceptorChain.addInterceptorBefore(AsyncInterceptor toAdd,
Class<? extends AsyncInterceptor> beforeInterceptor) |
boolean |
AsyncInterceptorChain.containsInterceptorType(Class<? extends AsyncInterceptor> interceptorType)
Checks whether the chain contains an interceptor with the given class.
|
boolean |
EmptyAsyncInterceptorChain.containsInterceptorType(Class<? extends AsyncInterceptor> interceptorType) |
boolean |
AsyncInterceptorChain.containsInterceptorType(Class<? extends AsyncInterceptor> interceptorType,
boolean alsoMatchSubClasses)
Checks whether the chain contains an interceptor with the given class, or a subclass.
|
boolean |
EmptyAsyncInterceptorChain.containsInterceptorType(Class<? extends AsyncInterceptor> interceptorType,
boolean alsoMatchSubClasses) |
void |
AsyncInterceptorChain.removeInterceptor(Class<? extends AsyncInterceptor> clazz)
Removes all the occurrences of supplied interceptor type from the chain.
|
void |
EmptyAsyncInterceptorChain.removeInterceptor(Class<? extends AsyncInterceptor> clazz) |
boolean |
AsyncInterceptorChain.replaceInterceptor(AsyncInterceptor replacingInterceptor,
Class<? extends AsyncInterceptor> toBeReplacedInterceptorType)
Replaces an existing interceptor of the given type in the interceptor chain with a new interceptor
instance passed as parameter.
|
boolean |
EmptyAsyncInterceptorChain.replaceInterceptor(AsyncInterceptor replacingInterceptor,
Class<? extends AsyncInterceptor> toBeReplacedInterceptorType) |
Modifier and Type | Class and Description |
---|---|
class |
BaseDistributionInterceptor
Base class for distribution of entries across a cluster.
|
class |
BiasedScatteredDistributionInterceptor |
class |
DistributionBulkInterceptor<K,V>
Interceptor that handles bulk entrySet and keySet commands when using in a distributed/replicated environment.
|
class |
L1LastChanceInterceptor
L1 based interceptor that flushes the L1 cache at the end after a transaction/entry is committed to the data
container but before the lock has been released.
|
class |
L1NonTxInterceptor
Interceptor that handles L1 logic for non-transactional caches.
|
class |
L1TxInterceptor
Interceptor that handles L1 logic for transactional caches.
|
class |
NonTxDistributionInterceptor
Non-transactional interceptor used by distributed caches that support concurrent writes.
|
class |
ScatteredDistributionInterceptor
This interceptor mixes several functions:
A) replicates changes to other nodes
B) commits the entry
C) schedules invalidation
On primary owner, the commit is executed before the change is replicated to other node.
|
class |
TriangleDistributionInterceptor
Non-transactional interceptor used by distributed caches that supports concurrent writes.
|
class |
TxDistributionInterceptor
Handles the distribution of the transactional caches.
|
class |
VersionedDistributionInterceptor
A version of the
TxDistributionInterceptor that adds logic to handling prepares when entries are
versioned. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractIracLocalSiteInterceptor
A
DDAsyncInterceptor with common code for all the IRAC related interceptors. |
class |
AbstractIracRemoteSiteInterceptor
An IRAC related interceptor that that handles the requests from the remote site.
|
class |
BaseRpcInterceptor
Acts as a base for all RPC calls
|
class |
BaseStateTransferInterceptor
A base class for a state transfer interceptor.
|
class |
BatchingInterceptor
Interceptor that captures batched calls and attaches contexts.
|
class |
BiasedEntryWrappingInterceptor |
class |
CacheLoaderInterceptor<K,V> |
class |
CacheMgmtInterceptor
Captures cache management statistics.
|
class |
CacheWriterInterceptor
Writes modifications back to the store on the way out: stores modifications back through the CacheLoader, either
after each method call (no TXs), or at TX commit.
|
class |
CallInterceptor
Always at the end of the chain, directly in front of the cache.
|
class |
ClusteredCacheLoaderInterceptor<K,V>
The same as a regular cache loader interceptor, except that it contains additional logic to force loading from the
cache loader if needed on a remote node, in certain conditions.
|
class |
ClusteringInterceptor
Base class for distribution interceptors.
|
class |
DistCacheWriterInterceptor
Cache store interceptor specific for the distribution and replication cache modes.
|
class |
EntryWrappingInterceptor
Interceptor in charge with wrapping entries and add them in caller's context.
|
class |
GroupingInterceptor
An interceptor that keeps track of the keys
added/removed during the processing of a
GetKeysInGroupCommand |
class |
InvalidationInterceptor
This interceptor acts as a replacement to the replication interceptor when the CacheImpl is configured with
ClusteredSyncMode as INVALIDATE.
|
class |
InvocationContextInterceptor |
class |
IsMarshallableInterceptor
Interceptor to verify whether parameters passed into cache are marshallables
or not.
|
class |
JmxStatsCommandInterceptor
Base class for all the interceptors exposing management statistics.
|
class |
NonTxIracLocalSiteInterceptor
Interceptor used by IRAC for non transactional caches to handle the local site updates.
|
class |
NonTxIracRemoteSiteInterceptor
Interceptor for non-transactional caches to handle updates from remote sites.
|
class |
NotificationInterceptor
The interceptor in charge of firing off notifications to cache listeners
|
class |
OptimisticTxIracLocalSiteInterceptor
Interceptor used by IRAC for optimistic transactional caches to handle the local site updates.
|
class |
OptimisticTxIracRemoteSiteInterceptor
Interceptor for optimistic transactional caches to handle updates from remote sites.
|
class |
PassivationCacheLoaderInterceptor<K,V> |
class |
PassivationClusteredCacheLoaderInterceptor<K,V> |
class |
PassivationWriterInterceptor
Handles store write operations when passivation enabled that don't entail reading the entry first
|
class |
PessimisticTxIracLocalInterceptor
Interceptor used by IRAC for pessimistic transactional caches to handle the local site updates.
|
class |
PessimisticTxIracRemoteSiteInterceptor
Interceptor for pessimsitic transactional caches to handle updates from remote sites.
|
class |
PrefetchInterceptor<K,V> |
class |
RetryingEntryWrappingInterceptor
Used in @{link org.infinispan.configuration.cache.CacheMode#SCATTERED_SYNC scattered cache}
The commit is executed in
ScatteredDistributionInterceptor
before replicating the change from primary owner. |
class |
ScatteredCacheWriterInterceptor
Similar to
DistCacheWriterInterceptor but as commands are not forwarded from primary owner
so we just write to the store all the time (with non-shared interceptors). |
class |
TransactionalExceptionEvictionInterceptor
Interceptor that prevents the cache from inserting too many entries over a configured maximum amount.
|
class |
TransactionalStoreInterceptor
An interceptor which ensures that writes to an underlying transactional store are prepared->committed/rolledback as part
of the 2PC, therefore ensuring that the cache and transactional store(s) remain consistent.
|
class |
TxInterceptor<K,V>
Interceptor in charge with handling transaction related operations, e.g enlisting cache as an transaction
participant, propagating remotely initiated changes.
|
class |
VersionedEntryWrappingInterceptor
Interceptor in charge with wrapping entries and add them in caller's context.
|
class |
VersionInterceptor
Interceptor installed when compatiblity is enabled.
|
Modifier and Type | Method and Description |
---|---|
<T extends AsyncInterceptor> |
AsyncInterceptorChainImpl.findInterceptorExtending(Class<T> interceptorClass) |
<T extends AsyncInterceptor> |
AsyncInterceptorChainImpl.findInterceptorWithClass(Class<T> interceptorClass) |
Modifier and Type | Method and Description |
---|---|
List<AsyncInterceptor> |
AsyncInterceptorChainImpl.getInterceptors() |
Modifier and Type | Method and Description |
---|---|
void |
AsyncInterceptorChainImpl.addInterceptor(AsyncInterceptor interceptor,
int position) |
boolean |
AsyncInterceptorChainImpl.addInterceptorAfter(AsyncInterceptor toAdd,
Class<? extends AsyncInterceptor> afterInterceptor) |
boolean |
AsyncInterceptorChainImpl.addInterceptorBefore(AsyncInterceptor toAdd,
Class<? extends AsyncInterceptor> beforeInterceptor) |
boolean |
AsyncInterceptorChainImpl.addInterceptorBefore(AsyncInterceptor toAdd,
Class<? extends AsyncInterceptor> beforeInterceptor,
boolean isCustom)
Deprecated.
|
void |
AsyncInterceptorChainImpl.appendInterceptor(AsyncInterceptor ci,
boolean isCustom) |
boolean |
AsyncInterceptorChainImpl.containsInstance(AsyncInterceptor interceptor) |
boolean |
AsyncInterceptorChainImpl.replaceInterceptor(AsyncInterceptor replacingInterceptor,
Class<? extends AsyncInterceptor> existingInterceptorType) |
Modifier and Type | Method and Description |
---|---|
boolean |
AsyncInterceptorChainImpl.addInterceptorAfter(AsyncInterceptor toAdd,
Class<? extends AsyncInterceptor> afterInterceptor) |
boolean |
AsyncInterceptorChainImpl.addInterceptorBefore(AsyncInterceptor toAdd,
Class<? extends AsyncInterceptor> beforeInterceptor) |
boolean |
AsyncInterceptorChainImpl.addInterceptorBefore(AsyncInterceptor toAdd,
Class<? extends AsyncInterceptor> beforeInterceptor,
boolean isCustom)
Deprecated.
|
boolean |
AsyncInterceptorChainImpl.containsInterceptorType(Class<? extends AsyncInterceptor> interceptorType) |
boolean |
AsyncInterceptorChainImpl.containsInterceptorType(Class<? extends AsyncInterceptor> interceptorType,
boolean alsoMatchSubClasses) |
void |
AsyncInterceptorChainImpl.removeInterceptor(Class<? extends AsyncInterceptor> clazz) |
boolean |
AsyncInterceptorChainImpl.replaceInterceptor(AsyncInterceptor replacingInterceptor,
Class<? extends AsyncInterceptor> existingInterceptorType) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractLockingInterceptor
Base class for various locking interceptors in this package.
|
class |
AbstractTxLockingInterceptor
Base class for transaction based locking interceptors.
|
class |
NonTransactionalLockingInterceptor
Locking interceptor to be used for non-transactional caches.
|
class |
OptimisticLockingInterceptor
Locking interceptor to be used by optimistic transactional caches.
|
class |
PessimisticLockingInterceptor
Locking interceptor to be used by pessimistic caches.
|
Modifier and Type | Class and Description |
---|---|
class |
BaseBackupInterceptor |
class |
NonTransactionalBackupInterceptor
Handles x-site data backups for non-transactional caches.
|
class |
OptimisticBackupInterceptor
Handles x-site data backups for optimistic transactional caches.
|
class |
PessimisticBackupInterceptor
Handles x-site data backups for pessimistic transactional caches.
|
Modifier and Type | Class and Description |
---|---|
class |
PartitionHandlingInterceptor |
Modifier and Type | Method and Description |
---|---|
List<AsyncInterceptor> |
GetCacheInterceptorChainAction.run() |
Modifier and Type | Class and Description |
---|---|
class |
StateTransferInterceptor
This interceptor has two tasks:
If the command's topology id is higher than the current topology id,
wait for the node to receive transaction data for the new topology id.
If the topology id changed during a command's execution, retry the command, but only on the
originator (which replicates it to the new owners).
If the cache is configured with asynchronous replication, owners cannot signal to the originator that they
saw a new topology, so instead each owner forwards the command to all the other owners in the new topology.
|
class |
TransactionSynchronizerInterceptor
With the Non-Blocking State Transfer (NBST) in place it is possible for a transactional command to be forwarded
multiple times, concurrently to the same node.
|
Copyright © 2021 JBoss by Red Hat. All rights reserved.