All Classes and Interfaces
Class
Description
Entry or key set backed by a cache.
Abstract class that is the basis for the Cache, Rebalance and Topology commands.
This is a base class that should be used when implementing a CacheEventFilterConverter that provides default
implementations for the
CacheEventFilter.accept(Object, Object, org.infinispan.metadata.Metadata, Object, org.infinispan.metadata.Metadata, EventType)
and Converter.convert(Object, Object, org.infinispan.metadata.Metadata) methods so they just call the
CacheEventFilterConverter.filterAndConvert(Object, Object, org.infinispan.metadata.Metadata, Object, org.infinispan.metadata.Metadata, EventType)
method and then do the right thing.Abstract stream that provides all of the common functionality required for all types of Streams including the various
primitive types.
Base class for local and remote transaction.
Abstract collection that uses an underlying Cache instance to do various operations.
Factory that creates components used internally within Infinispan, and also wires dependencies into the components.
Deprecated, for removal: This API element is subject to removal in a future version.
Support class for
CustomFailurePolicy.Stuff common to WriteCommands
Similar to
AbstractDelegatingCache, but for AdvancedCache.This is a convenient base class for implementing a cache delegate.
Delegate that forwards all the of the method calls to the underlying cache stream.
This is a convenient base class for implementing a cache manager delegate.
Class to be extended to allow some control over the
PerCacheInboundInvocationHandler
in tests.Delegating data container that delegates all calls to the container returned from
AbstractDelegatingInternalDataContainer.delegate()Designed to be overwrite.
Base class for both Sync and XAResource enlistment adapters.
Base class for those commands that can carry flags.
An abstract internal cache entry that is typically stored in the data container
Abstract class implemenation for a segmented data container.
An abstract ProtoStream based
Marshaller and StreamAwareMarshaller implementation that is the basis
of the Persistence and Global marshallers.Common features of transaction and invocation contexts
Base class for InvocationContextFactory implementations.
A
DDAsyncInterceptor with common code for all the IRAC related interceptors.This is a base class that should be used when implementing a KeyValueFilterConverter that provides default
implementations for the
KeyValueFilter.accept(Object, Object, org.infinispan.metadata.Metadata)
and Converter.convert(Object, Object, org.infinispan.metadata.Metadata) methods so they just call the
KeyValueFilterConverter.filterAndConvert(Object, Object, org.infinispan.metadata.Metadata)
method and then do the right thing.Functionality common to both
CacheManagerNotifierImpl and
CacheNotifierImplAbstract class
Base class for various locking interceptors in this package.
Abstract class to create mixed
SiteStatus.AbstractModuleConfigurationBuilder.
A component factory for creating components scoped per-cache.
A passivation manager
AbstractPersistenceConfigurationChildBuilder.
A remote invocation request.
Abstract store configuration that should be extended when the store configuration supports being segmented.
A
SiteStatus builder based on its online and offline members.AbstractStoreSerializer.
Abstract
ThreadPoolExecutorFactory that contains commons variables for configuring a thread poolBase class for commands that carry topology id.
An abstract transaction boundary command that holds a reference to a
GlobalTransactionSupport class for
TxInvocationContext.Base class for transaction based locking interceptors.
An abstract implementation of a Visitor that delegates all visit calls to a default handler which can be overridden.
A key value filter that accepts all entries found.
WARNING: Generated code!
An action represents a step in
PerCacheInboundInvocationHandler.A listener that is invoked when an
Action is completed.Orders multiple actions/tasks based on a key.
The state used by an
Action.The status for an
Action.AddCacheDependencyAction.
CacheManagerAddListenerAction.
CacheManagerAddListenerAction.
Add logger listener action.
An encapsulation of a JGroups
ExtendedUUID with a NodeVersion, site id, rack id, and a machine id.WARNING: Generated code!
Cache
Address instancesAn advanced interface that exposes additional methods not available on
Cache.Key partitioner that maps keys to segments using information contained in
AffinityTaggedKey.WARNING: Generated code!
Configures the
EmbeddedCacheManager ClassAllowList.Signals that all owners of a key have been lost.
A
XSiteEntryMergePolicy that removes the key if a conflict is detected.WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
Interface for sequential interceptors.
Interceptor chain using
AsyncInterceptors.Knows how to build and manage a chain of interceptors.
A delegating NonBlockingStore implementation that batches write operations and runs the resulting batches on the
delegate store in a non overlapping manner.
A
XSiteStateProviderState for asynchronous cross-site replication state transfer (IRAC).Configuration for the async cache store.
Configuration for the async cache store.
Enumerates the attributes used in Infinispan
AuditContext.
AuditLogger.
AuditMessages.
Warning this class consists of generated code.
AuthorizationConfiguration.
AuthorizationConfigurationBuilder.
The AuthorizationManager is a cache-scoped component which verifies that the
Subject
associated with the current thread, or explicitly specified, has the requested permissions.AuthorizationManagerImpl.
PrincipalRoleMapperContextImpl.
AuthorizationPermission.
Authorizer.
Component factories that implement this interface can be instantiated automatically by component registries when
looking up components.
A
Response implementation for command XSiteAutoTransferStatusCommand.WARNING: Generated code!
A
ResponseCollector that merges AutoStateTransferResponse.Thrown when a partition happened and the key that an operation tries to access is not available.
Implementations decide what to do when the cache membership changes, either because new nodes joined, nodes left,
or there was a merge.
Contains information about the current state of the cache.
PartitionHandlingManager implementation when the cluster is always available.Exception to be used to signal failures to backup to remote sites.
Defines the possible behaviour in case of failure during x-site.
Defines the remote caches for which this cache acts as a backup.
A command that represents an acknowledge sent by a backup owner to the originator.
WARNING: Generated code!
A command that tell a backup owner to ignore a sequence id after the primary failed to send a regular write command.
WARNING: Generated code!
Component present on a backup site that manages the backup information and logic.
Represents a response from a backup replication call.
Component responsible with sending backup data to remote sites.
A write operation sent from the primary owner to the backup owners.
Base class for an interceptor in the new asynchronous invocation chain.
Common logic to handle
CacheRpcCommand.Interface that defines the base methods of all streams returned from a
Cache.Functional interface that is used as a callback when segments are completed.
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.Base class for distribution of entries across a cluster.
Implementation with the default handling methods and utilities methods.
Acts as a base for all RPC calls
A base class for a state transfer interceptor.
Common code for
AsyncProviderState and SyncProviderState implementation.Basic dependency injection container.
BasicEventLogger.
A container for holding thread locals for batching, to be used with the
BatchingCache.startBatch() and
BatchingCache.endBatch(boolean) calls.Interceptor that captures batched calls and attaches contexts.
Not really a transaction manager in the truest sense of the word.
A simple wrapper class, necessary for Transactional stores, which allows MarshalledEntries and Object keys to be passed
to a store implementation in order.
A Bifuncion wrapper that uses the cache's underlying DataConversion objects to perform its operations.
WARNING: Generated code!
Utility method for inserting and retrieving values from to/from a byte[]
Manager utility for blocking operations that runs tasks on the blocking executor and returns a
CompletionStage or Publisher that continues on the non-blocking executor, similar
to stage.handleAsync(callback, blockingExecutor).whenCompleteAsync(NOOP, nonBlockingExecutor).Executor interface that submits task to a blocking pool that returns a stage that is guaranteed
to run any chained stages on a non-blocking thread if the stage is not yet complete.
A special Runnable that is only sent to a thread when it is ready to be
executed without blocking the thread
Used in
org.infinispan.util.concurrent.BlockingTaskAwareExecutorServiceExecutor service that is aware of
BlockingRunnable and only dispatch the runnable to a thread when it has low
(or no) probability of blocking the thread.A special executor service that accepts a
BlockingRunnable.Bounded implementation of segmented data container.
The return value of
TakeOfflineManager.bringSiteOnline(String).A simple class which encapsulates a byte[] representation of a String using a predefined encoding (currently UTF-8).
WARNING: Generated code!
The central interface of Infinispan.
Change the availability of a cache.
WARNING: Generated code!
Interface that describes how a cache can be injected into another object.
Entry set backed by a cache.
Key set backed by a cache.
A collection type that returns special Cache based streams that have additional options to tweak behavior.
Helper class designed to be used to create a serializable Collector for use with
CacheStream.collect(Collector) from a supplier of a collector.CacheConfigurationMBeanImpl.
Similar to
Stats but in the scope of a single per-node CacheContainer.Cache container statistics
WARNING: Generated code!
This annotation should be used on methods that need to be notified when cache entries are evicted.
This event subtype is passed in to any method annotated with
CacheEntriesEvicted.An entry that is stored in the data container
This annotation should be used on methods that need to be notified when a cache entry is activated.
This event subtype is passed in to any method annotated with
CacheEntryActivated.WARNING: Generated code!
This annotation should be used on methods that need to be notified when a cache entry is created.
This event subtype is passed in to any method annotated with
CacheEntryCreated.A transactional event subtype that additionally expose a key as such events pertain to a specific cache entry.
This annotation should be used on methods that need to be notified when a cache entry is expired
Methods annotated with this annotation should be public and take in a single parameter, a
CacheEntryExpiredEvent otherwise an IncorrectListenerException will be thrown when registering your cache listener.This event subtype is passed in to any method annotated with
CacheEntryExpired.WARNING: Generated code!
Tests if a
CacheEntry belongs to a group.WARNING: Generated code!
This annotation should be used on methods that need to be notified when a cache entry is invalidated.
Notifies a listener of an invalidation event.
Additional listener methods specific to caches.
This annotation should be used on methods that need to be notified when a cache entry is loaded from a
NonBlockingStore.This event subtype is passed in to any method annotated with
CacheEntryLoaded.This annotation should be used on methods that need to be notified when a cache entry has been modified.
This event subtype is passed in to any method annotated with
CacheEntryModified
The CacheEntryModifiedEvent.getValue() method's behavior is specific to whether the callback is triggered before or after the event
in question.This annotation should be used on methods that need to be notified when cache entries are passivated.
This event subtype is passed in to any method annotated with
CacheEntryPassivated.This annotation should be used on methods that need to be notified when a cache entry is removed from the cache.
This event subtype is passed in to any method annotated with
CacheEntryRemoved.Implementation of a size calculator that calculates only the size of the value assuming it is an InternalCacheEntry.
This annotation should be used on methods that need to be notified when a cache entry is visited.
This event subtype is passed in to any method annotated with
CacheEntryVisited.A converter that can be used to convert the value given for an event.
Converter that is implemented by using the provided CacheEventConverter.
WARNING: Generated code!
Factory that can produce CacheEventConverters
A filter that can be used to tell if an event should be raised or not.
KeyValueFilter that is implemented by using the provided CacheEventFilter.
WARNING: Generated code!
This interface is an optimization that can be used when an event filter and converter are most efficiently used as
the same object composing the filtering and conversion in the same method invocation.
WARNING: Generated code!
Factory that can produce
CacheEventFilterConverter instances.Factory that can produce CacheEventFilters
Static factory class that contains utility methods that can be used for performing proper transformations from
KeyValueFilter, Converter and KeyValueFilterConverter to appropriate distributed stream
instances.Cache health information.
WARNING: Generated code!
Function that is used to encapsulate multiple intermediate operations and perform them lazily when the function
is applied.
WARNING: Generated code!
If
Configuration.statistics() is enabled, then class will register all
the MBeans from cache local's ConfigurationRegistry to the MBean server.A node is requesting to join the cluster.
WARNING: Generated code!
Thrown when a cache fails to join a cluster
This class contains the information that a cache needs to supply to the coordinator when starting up.
WARNING: Generated code!
A node is signaling that it wants to leave the cluster.
WARNING: Generated code!
WARNING: Generated code!
Registers all the components from global component registry to the mbean server.
Creates and registers metrics for all components from a cache manager's global component registry.
Notifications for the cache manager
Global, shared notifications on the cache manager.
Creates and registers metrics for all components from a cache's component registry.
Captures cache management statistics.
A mixed
SiteStatus.Cache replication mode.
A response that signals the named cache is not running on the target node.
CacheNotFoundResponse$___Marshaller_a03d42fe7cfe7ec3acb9696c22c4589893c2629ea83bf6d77cf41f7e57e5bc52
WARNING: Generated code!
Public interface with all allowed notifications.
Helper class that handles all notifications to registered listeners.
WARNING: Generated code!
This class implements the parser for Infinispan/AS7/EAP/JDG schema files
CachePermission.
CachePermissionCollection.
Publisher to be used for non-blocking operations across the cache data set.
CacheRoleImpl.
WARNING: Generated code!
The
RpcManager only replicates commands wrapped in a CacheRpcCommand.A set that also must implement the various
CacheCollection methods for streams.A
CacheSet that allows for a different set to be mapped as a different instance wtih values replaced on
request.Tell members to shutdown cache.
WARNING: Generated code!
A member is requesting a cache shutdown.
WARNING: Generated code!
A per-cache
SiteStatus builder.This annotation should be used on methods that need to be notified when a cache is started.
This event is passed in to any method annotated with
CacheStarted.Cache State information stored in a cluster-wide cache
WARNING: Generated code!
The coordinator is requesting information about the running caches.
WARNING: Generated code!
WARNING: Generated code!
This annotation should be used on methods that need to be notified when a cache is stopped.
This event is passed in to any method annotated with
CacheStopped.Reducer implementation for Distributed Publisher that converts between CacheStream operations to an
appropriate Reducer
WARNING: Generated code!
CachePrincipalPair.
The status of a cache from a distribution/state transfer point of view.
Phase of the rebalance process.
WARNING: Generated code!
The link between
LocalTopologyManager and StateTransferManager.Utility methods related to
CacheTopology.Defines the state a infinispan transaction should have.
Cache replication mode.
Signals a backup site was unreachable.
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.
Always at the end of the chain, directly in front of the cache.
A rewriter which can convert a name to uppercase or lowercase
WARNING: Generated code!
Interface that enhances
FilteringListenable with the possibility of specifying the
ClassLoader which should be set as the context class loader for the invoked
listener methodInterface that enhances
Listenable with the possibility of specifying the
ClassLoader which should be set as the context class loader for the invoked
listener methodUsed in
ClearInvocationContext to process the ClearCommand.WARNING: Generated code!
Implementation of
InvocationContext used by the ClearCommand.This interface describes methods required for a cluster listener to be able to be bootstrapped and properly notified
when a new event has been raised from the cluster.
Similar to
Stats but cluster wide.Keeps track of a cache's status: members, current/pending consistent hashes, and rebalance status
Cluster wide container statistics.
BackupReceiver implementation for clustered caches.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.
Issues a remote getAll call.
WARNING: Generated code!
Issues a remote get call.
WARNING: Generated code!
A filter that tests the validity of
ClusteredGetCommands.A
TransactionOriginatorChecker implementation for clustered caches.This is an event designed for use with cluster listeners solely.
WARNING: Generated code!
Constructs the data container.
ClusterExecutionPolicy controls how which nodes commands submitted via
ClusterExecutor.A cluster executor that can be used to invoke a given command across the cluster.
Static factory methods to construct a ClusterExecutor
Allows for cluster based expirations to occur.
Cluster health information.
Defines clustered characteristics of the cache.
Defines clustered characteristics of the cache.
Abstractization for logic related to different clustering modes: replicated or distributed.
This logic is used in distributed mode caches.
This logic is used in invalidation mode caches.
This logic is used in local mode caches.
This logic is used in replicated mode caches.
Base class for distribution interceptors.
ClusteringInterceptor.ClusteredGetAllFuture.completeExceptionally(Throwable) must be called from synchronized block since we must not complete
the future (exceptionally) when we're accessing the context - if there was an exception and we would retry,
the context could be accessed concurrently by dangling handlers and retry execution (that does not synchronize
on the same future).This DistributedCallable is used to remove registered
RemoteClusterListener on each of the various nodes
when a cluster listener is unregistered from the cache.WARNING: Generated code!
This DistributedCallable is used to install a
RemoteClusterListener on the resulting node.WARNING: Generated code!
ClusterPermissionMapper.
Manages distribution of various publisher operations that are ran locally and/or sent to remote nodes.
ClusterPublisherManager that determines targets for the given segments and/or keys and then sends to local and
remote nodes in parallel collecting results to be returned.
ClusterRoleMapper.
Maintains the topology for all the caches in the cluster.
Factory for ClusterTopologyManager implementations.
The
ClusterTopologyManager implementation.Information about the JGroups cluster.
A collection that maps another one to a new one of a possibly different type.
Represents the ack collector for a write operation in triangle algorithm.
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
An acknowledge collector for Triangle algorithm used in non-transactional caches for write operations.
Represents a unique identifier for non-transaction write commands.
WARNING: Generated code!
A factory to build commands, initializing and injecting dependencies accordingly.
Command corresponding to the 2nd phase of 2PC.
WARNING: Generated code!
Keeps track of the keys updated by normal operation and state transfer.
Deprecated.
use
CommonNameRoleMapper insteadCommonNameRoleMapper.
Command used by the recovery tooling for forcing transaction completion .
WARNING: Generated code!
Component lifecycle management
Factory for Infinispan components.
Reference to a component.
Named cache specific components
Different states a component may be in.
Allows AND-composing several cache event filters.
Allows AND-composing several key/value filters.
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
Thrown when the version of entry has changed between loading the entry to the context and committing new value.
A mixture between a
CompletableFuture and a Condition.A basic locking mechanism that uses the
InternalCacheNames.CONFIG_STATE_CACHE_NAME
to ensure only one operation can proceed.This annotation should be used on methods that need to be notified when a configuration is changed.
This event is passed in to any method annotated with
ConfigurationChanged.ConfigurationHolder.
It manages all the configuration for a specific container.
ConfigurationParser.
ConfigurationParserListener.
Helper configuration methods.
Configuration storage
A
ConflictManager factory for cache instances.Start conflict resolution.
WARNING: Generated code!
A consistent hash algorithm implementation.
Factory for
ConsistentHash instances.Constants used as keys within a persisted consistent hash
Various public constant names, used by Infinispan's metrics support.
Exception that is thrown when exception based eviction is enabled and the cache is full
A mixed
SiteStatus.A per-container
SiteStatus builder.An interface to build
InvocationContext.Converter that can be used to transform a given entry to a different value.
WARNING: Generated code!
Serializes an Infinispan configuration to an
ConfigurationWriterStatic factory class for producing executor factories in the core module
Factory for generating immutable type wrappers for core types.
A concurrency structure that invokes a
Runnable when its count reaches zero.Stores the
CounterConfiguration.Used for implementing custom policies in case of communication failures with a remote site.
Interface to implement if the class want to register more metrics to Micrometer than the methods annotated with
ManagedAttribute.StoreConfigurationBuilder used for stores/loaders that don't have a configuration builder
Thrown when a cyclic dependency exist
Commands of this type manipulate data in the cache.
The main internal data structure which stores entries.
Constructs the data container
This is an iterator that will iterate upon the data container.
Handle conversions for Keys or values.
WARNING: Generated code!
Deprecated.
Since 11.0.
Ordering construct allowing concurrent operations that wish to do operations upon the same key to wait until
the most recently registered operation is complete in a non blocking way.
This annotation should be used on methods that need to be notified when a rehash starts or ends.
An event passed in to methods annotated with
DataRehashed.Mixes features from DataCommand and WriteCommand
Interface for async interceptors using double-dispatch.
An interface to implement the deadlock algorithm.
Exception signaling detected deadlocks.
A decorator to a cache, which can be built with a specific set of
Flags.DecoratedEventLogger.
The default implementation of
EmbeddedCacheManagerAdminDefault
ConsistentHash implementation.DefaultConsistentHash$___Marshaller_72e046f2d643b0377d964c75525999a723791ab876f8aaba63d75ab943289f60
WARNING: Generated code!
Default implementation of
ConsistentHashFactory.WARNING: Generated code!
DefaultDataContainer is both eviction and non-eviction based data container.
Default executor factory that creates executors using the JDK Executors service.
Default implementation of
IracManager.A default implementation for
IracTombstoneManager.Default implementation of
IracVersionGenerator.The default
LockManager implementation for transactional and non-transactional caches.The default implementation for
PendingLockManager.A list of
Action to be executed to check when it is ready.The default response generator for most cache modes
Creates scheduled executors using the JDK Executors service
DataContainer implementation that internally stores entries in an array of maps.
The default implementation of
TakeOfflineManager.Thread factory based on JBoss Thread's JBossThreadFactory.
The default
Runnable for the remote commands receives.Default implementation for
TwoWayKey2StringMapper that knows how to handle all primitive
wrapper keys and Strings.The default
XSiteEntryMergePolicy implementation.Implementation of
XSiteMetricsCollector to use when asynchronous backups (cross-site replication) are
configured.DefineConfigurationAction.
A wrapper around a
CacheEntryListenerInvocation that keeps a reference to the FilterIndexingServiceProvider instance that handles this invocation.A delegate
Marshaller implementation for the user marshaller that ensures that the Marshaller.start() and
Marshaller.stop() of the configured marshaller are called and logged as required.Used in RPC, it defines how the messages are delivered to the nodes.
Enumeration defining the possible delivery guarantees for entries.
Graph to track dependencies between objects
For optimistic transactions, it signals the update from the remote site is not valid (old version or conflict
resolution rejected it).
Cache store interceptor specific for the distribution and replication cache modes.
WARNING: Generated code!
Implementation of
CacheStream that provides support for lazily distributing stream methods to appropriate
nodesImplementation of
DoubleStream that utilizes a lazily evaluated distributed back end execution.Implementation of
IntStream that utilizes a lazily evaluated distributed back end execution.Implementation of
LongStream that utilizes a lazily evaluated distributed back end execution.A component that manages the distribution of elements across a cache cluster
The default distribution manager implementation
A
DoubleStream that has additional methods to allow for Serializable instances.Modules implementing
ModuleLifecycle might need additional control over the created
components.An enumeration of all the recognized XML element local names, by name.
A simple
TransactionManager implementation.EmbeddedCacheManager is an CacheManager that runs in the same JVM as the client.
Cache manager operations which affect the whole cluster.
An exception to encapsulate an error when starting up a cache manager
WARNING: Generated code!
A JGroups
ProtocolStackConfigurator whichWARNING: Generated code!
WARNING: Generated code!
Metadata class for embedded caches.
WARNING: Generated code!
The default implementation of
TimeService.A
Transaction implementation used by EmbeddedBaseTransactionManager.Simple transaction manager implementation that maintains transaction state in memory only.
Returns an instance of
EmbeddedTransactionManager.A
UserTransaction implementation that uses EmbeddedTransactionManager.Factory for building global-scope components which have default empty constructors
Simple factory that just uses reflection and an empty constructor of the component type.
A NO-OP implementation of
RaftManager.Cache decoration that makes use of the
Transcoder to convert between storage value and
read/write value.Function that uses an encoder to converter entries from the configured storage format to
the requested format.WARNING: Generated code!
Function that uses a keyEncoder to converter keys from the configured storage format to
the requested format.WARNING: Generated code!
Manages
Transcoder instances.Factory for
EncoderRegistryImpl objects.Function that uses a valueEncoder to converter values from the configured storage format
to the requested format.WARNING: Generated code!
Controls encoding configuration for keys and values in the cache.
This is a marker interface to signal that this function may perform an encoding of the provided value.
Executor Factory used for blocking executors which utilizes
EnhancedQueueExecutor internally.A factory for constructing
MVCCEntry instances for use in the InvocationContext.EntryFactory implementation to be used for optimistic locking scheme.WARNING: Generated code!
Interface that describes methods used for loading entries from the underlying
PersistenceManager and store those entries into the
DataContainer if necessary.Interface that can look up MVCC wrapped entries.
A registry for
EntryMergePolicyFactory implementations, which allows EntryMergePolicy implementations
to be eagerly/lazily loaded across multiple contexts.Object to hold metadata bytes and timestamps.
Helper for reading/writing entries into file.
Command implementation for
Map.entrySet() functionality.WARNING: Generated code!
WARNING: Generated code!
A version is used to compare entries against one another.
Entry views expose cached entry information to the user.
Expose read-only information about a cache entry potentially associated
with a key in the functional map.
Expose information about a cache entry potentially associated with a key
in the functional map, and allows that cache entry to be written with
new value and/or new metadata parameters.
Expose a write-only facade for a cache entry potentially associated with a key
in the functional map which allows the cache entry to be written with
new value and/or new metadata parameters.
Entry views implementation class holder.
Wrapper for CacheEntry(s) that can be used to update the cache when it's value is set.
Interceptor in charge with wrapping entries and add them in caller's context.
WARNING: Generated code!
An interface that defines common characteristics of events
Common characteristics of events that occur on a cache manager
Basic implementation of an event that covers all event types.
Implementation of cache manager events
EventLog describes an event log's attributes.
EventLogCategory.
EventLogger provides an interface for logging event messages.
EventLogLevel.
EventLogManager.
EventLogManagerImpl.
Enum that provides information to allow for an event to know which type and if this event was generated due to a
retry usually caused by a topology change while replicating.
Simple wrapper that keeps the original key along with the converted event and command.
Central component that deals with eviction of cache entries.
Supported eviction strategies
A command that represents an exception acknowledge sent by any owner.
WARNING: Generated code!
A response that encapsulates an exception
WARNING: Generated code!
A sync
InvocationStage for Throwable.Request implementation that waits for responses from multiple target nodes.
Exectues given tasks in provided executor.
Configures executor factory.
Controls the default expiration settings for entries in the cache.
Controls the default expiration settings for entries in the cache.
Central component that deals with expiration of cache entries.
Constructs the expiration manager
WARNING: Generated code!
Provide utility methods for dealing with expiration of cache entries.
Interface to implement an exponential back-off algorithm that retries the request based on the result of the remote
operation.
The default
ExponentialBackOff implementation for IRAC (asynchronous cross-site replication).An extended
LockPromise interface that allows a better control over it.A JGroups
JGroupsChannelConfigurator which loads configuration from an XML file supplied as an InputStreamProvides resource management for files - only limited amount of files may be opened in one moment, and opened file
should not be deleted.
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
A service provider for filter indexing services.
A Listenable that can also filter events based on key
Response collector supporting
JGroupsTransport.invokeRemotelyAsync(Collection, ReplicableCommand, ResponseMode, long, ResponseFilter, DeliverOrder).WARNING: Generated code!
Available flags, which may be set on a per-invocation basis.
Flags modify behavior of command such as whether or not to invoke certain commands remotely, check cache store etc.
Pre-computed bitsets containing each flag.
Copied from rxjava3 80c83a4e000f0d054ea88a3bd500d36c2c041b05
This has been modified to allow for Flowable create method to be invoked per subscription request instead of
during the initial subscribe, which may not even include a request of any size.
A class designed to forward all method invocations for a CacheEntry to the provided delegate.
A command that carries operation rather than final value.
Top level functional map interface offering common functionality for the
read-only, read-write, and write-only operations that can be run against a
functional map asynchronously.
Exposes read-only operations that can be executed against the functional map.
Exposes read-write operations that can be executed against the functional map.
Exposes write-only operations that can be executed against the functional map.
Functional map implementation.
Listener notifier.
WARNING: Generated code!
A transaction manager lookup class that attempts to locate a TransactionManager.
Retrieves multiple entries at once.
GetCacheAction.
GetCacheManagerConfigurationAction.
GetCacheEntryAction.
GetCacheEntryAction.
Used to fetch a full CacheEntry rather than just the value.
GetClusterExecutorAction.
GetEmbeddedCacheManagerAction.
Rpc to obtain all in-doubt prepared transactions stored on remote nodes.
WARNING: Generated code!
Command used by the recovery tooling for obtaining the list of in-doubt transactions from a node.
WARNING: Generated code!
Implements functionality defined by
Map.get(Object) and
Map.containsKey(Object) operationsGetOrCreateCacheAction.
GetOrCreateCacheAction.
GetUnwrappedCacheAction.
GetUnwrappedNameCacheAction.
GlobalAuthorizationConfiguration.
GlobalAuthorizationConfigurationBuilder.
A global component registry where shared components are stored.
Configuration component that exposes the global configuration.
The
GlobalConfigurationManager is the main interface for sharing runtime configuration state across a cluster.Implementation of
GlobalConfigurationManagerListens to events on the global state cache and manages cache configuration creation / removal accordingly
Interface used to initialise the
GlobalMarshaller's SerializationContext using the specified Pojos, Marshaller implementations and provided
.proto schemas.WARNING: Generated code!
InboundInvocationHandler implementation that handles all the ReplicableCommand.Configures JMX for the cache manager and its caches.
A globally-scoped marshaller for cluster communication.
Configuration for metrics.
Configures the types of metrics gathered and exported via Micrometer metrics for all caches owned by this Cache Manager.
GlobalRoleConfigurationBuilder.
Commands correspond to specific areas of functionality in the cluster, and can be replicated using the
GlobalInboundInvocationHandler.GlobalSecurityConfiguration.
GlobalSecurityConfigurationBuilder.
GlobalSecurityConfigurationChildBuilder.
GlobalSecurityManager.
Factory for GlobalSecurityManager implementations
GlobalSecurityManagerImpl.
GlobalStateConfiguration.
GlobalStateConfigurationBuilder.
GlobalStateManager.
GlobalStateManagerImpl.
GlobalStateProvider.
Configuration for tracing.
Uniquely identifies a transaction that spans all JVMs in a cluster.
WARNING: Generated code!
A per-container (cache manager) cross-site admin operations.
Identifies the key for a group.
User applications may implement this interface in order to customize the compution of groups in cases when the modifying the
key is not possible, or when the value determined by the
Group annotation needs customizing.Key partitioner that uses
Group annotations to map
grouped keys to the same segment.Control's key grouping.
Configuration for various grouper definitions.
Configuration for various grouper definitions.
Allows fine-tuning of rehashing characteristics.
Allows fine-tuning of rehashing characteristics.
Key partitioner that computes a key's segment based on a hash function.
An entry point for checking health status.
A Contract for exposing Health API over the JMX.
General Health status.
A hear-beat command used to ping members in
ClusterTopologyManagerImpl.confirmMembersAvailable().WARNING: Generated code!
Information about the host.
WARNING: Generated code!
WARNING: Generated code!
IdentityRoleMapper.
WARNING: Generated code!
A filter that only expects responses from an initial set of targets.
A cache entry that is immortal/cannot expire
WARNING: Generated code!
An immortal cache value, to correspond with
ImmortalCacheEntryWARNING: Generated code!
This context is a non-context for operations such as eviction which are not related
to the method invocation which caused them.
An immutable implementation of
LocalConfigurationStorage which does not allow cache creation/removal.Interface to invoke when the
Transport receives a command from other node
or site.Factory class that creates instances of
PerCacheInboundInvocationHandler.Inbound state transfer task.
Thrown when an incorrectly annotated class is added as a cache listener using the
Listenable.addListener(Object) API.An interface indicating that a version of this type can be incremented.
A marker interface for filters that can be handled efficiently by a
FilterIndexingServiceProvider.Configures indexing of entries in the cache for searching.
Configures indexing of entries in the cache for searching.
Affects how cache operations will be propagated to the indexes.
Allows to define some mass indexing operations (e.g.: purge or reindex) to trigger when the cache starts.
An object describing in doubt transaction's state.
WARNING: Generated code!
Versions can be compared to each other to result in one version being before, after or at the same time as another
version.
A special lock for Infinispan cache.
Aggregates the initialisation state needed by org.infinispan.persistence.spi.NonBlockingStore.
Handles the submission and response handling of an arbitrary amount of address
segments.
A
IntStream that has additional methods to allow for Serializable instances.Factory class that builds an interceptor chain based on cache configuration.
An intermediate cache stream used when an intermediate operation that requires both a remote and local portion
An intermediate double cache stream used when an intermediate operation that requires both a remote and local portion
An intermediate int cache stream used when an intermediate operation that requires both a remote and local portion
An intermediate long cache stream used when an intermediate operation that requires both a remote and local portion
The various intermediate types.
This interface is used to hold methods that are only available to internal implementations.
Interface for internal cache entries that expose whether an entry has expired.
An internal factory for constructing Caches.
InternalCacheRegistry.
InternalCacheRegistryImpl.
Base class for internal classes used in cache collections.
A representation of an InternalCacheEntry that does not have a reference to the key.
Interface describing methods of a data container where operations can be indexed by the segment of the key
stored in the map.
A factory for
InternalCacheEntry and InternalCacheValue instances.An implementation that generates non-versioned entries
Interface describing the internal operations for the the ExpirationManager.
WARNING: Generated code!
Removes an entry from memory.
WARNING: Generated code!
Invalidates an entry in a L1 cache (used with DIST mode)
WARNING: Generated code!
A
CacheLoaderInterceptor extension to add CacheType.INVALIDATION specific logic to load data from
persistence.Extends the
CacheWriterInterceptor to add logic for CacheType.INVALIDATION.This interceptor acts as a replacement to the replication interceptor when the CacheImpl is configured with
ClusteredSyncMode as INVALIDATE.
Thrown when client makes cache usage errors.
An invalid response
Thrown if an operation is to be performed on an invalid transaction context.
Base interface for all callbacks used by
BaseAsyncInterceptor and InvocationStage methods.A context that contains information pertaining to a given invocation.
Factory for
InvocationContext objects.It invokes the
VisitableCommand through this cache AsyncInterceptorChain.A partial command invocation, either completed or in progress.
Sends a cleanup request from the primary owner to the backup owners.
WARNING: Generated code!
A clear request that is sent to the remote site by
IracManager.WARNING: Generated code!
Used by asynchronous cross-site replication, it aggregates response from multiple sites and returns
IracBatchSendResult.An entry version for the IRAC algorithm (async cross site replication).
WARNING: Generated code!
Executes the "IRAC" sending task in a single thread.
It manages the keys changed in the local cluster and sends to all asynchronous backup configured.
WARNING: Generated code!
The metadata stored for an entry needed for IRAC (async cross-site replication).
WARNING: Generated code!
A request for a new
IracMetadata for a giver segment.WARNING: Generated code!
A command received by the primary owner with a list of possible stale keys.
WARNING: Generated code!
A
WriteCommand used to handle updates from the remote site (for asynchronous cross-site replication).WARNING: Generated code!
A multi-key cross-site requests.
WARNING: Generated code!
Requests the state for a given segments.
WARNING: Generated code!
A response collector for an asynchronous cross site requests.
The IRAC state for a given key.
WARNING: Generated code!
A
XSiteCacheRequest to check tombstones for IRAC algorithm.WARNING: Generated code!
A
CacheRpcCommand to clean up tombstones for IRAC algorithm.WARNING: Generated code!
A data class to store the tombstone information for a key.
WARNING: Generated code!
Stores and manages tombstones for removed keys.
A
CacheRpcCommand to check if one or more tombstones are still valid.WARNING: Generated code!
A
BaseRpcCommand to check tombstones for IRAC algorithm.WARNING: Generated code!
Response for a state request with the tombstones stored in the local node.
WARNING: Generated code!
A request that is sent to the remote site by
IracManager.WARNING: Generated code!
An update request that is sent to the remote site by
IracManager.It transfers the current versions stored in
IracVersionGenerator to the other nodes when joins/leaving events
occurs.WARNING: Generated code!
Utility methods from IRAC (async cross-site replication)
A version generator for the IRAC protocol.
Extends
XSiteBackup class with logging configuration.Interceptor to verify whether parameters passed into cache are marshallables
or not.
Various transaction isolation levels as an enumerated class.
Deprecated, for removal: This API element is subject to removal in a future version.
use
IsolationLevel insteadJTA standalone TM lookup (JBoss AS 7 and earlier, and WildFly 8, 9, and 10).
Stores and register metrics statistics related to JGroups, including the protocol metrics and per destination metrics
information (latency, bytes sent, etc.).
Concrete implementation of
JGroupsMetricsManager.An encapsulation of a JGroups transport.
Interface containing common cache management operations
Base class for all the interceptors exposing management statistics.
Defines the logic of mapping a key object to a String.
Defines a service that generates keys to be mapped to specific nodes in a distributed(vs. replicated) cluster.
Factory for
KeyAffinityService.Implementation of KeyAffinityService.
A listener for
KeyAwareLockPromise.An extension of
LockPromise that contains a key associated to the lock.WARNING: Generated code!
Used for generating keys; used by
KeyAffinityService to generate the affinity keys.Map keys to segments.
Key partitioner factory that uses the hash function defined in the configuration.
Command implementation for
Map.keySet() functionality.A filter for keys with their values.
CacheEventFilter that implements it's filtering solely on the use of the provided KeyValueFilter
WARNING: Generated code!
WARNING: Generated code!
This interface is an optimization that can be used when a filter and converter are most efficiently used as the same
object composing the filtering and conversion in the same method invocation.
CacheEventFilterConverter that uses an underlying KeyValueFilterConverter to do the conversion and
filtering.WARNING: Generated code!
Factory for
KeyValueFilterConverter instancesSize calculator that takes into account not only key and value but also metadata.
Holds logically related key-value pairs or binary tuples.
WARNING: Generated code!
Holder for known named component names.
Configures the L1 cache behavior in 'distributed' caches instances.
Configures the L1 cache behavior in 'distributed' caches instances.
A
InternalCacheEntry implementation to store a L1 entry.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.
Manages the L1 Cache, in particular recording anyone who is going to cache an
a command that a node responds to so that a unicast invalidation can be sent
later if needed.
Metadata implementation that must be passed to the DataContainer.put(Object, Object, org.infinispan.metadata.Metadata) when the entry to store
is a L1 entry.A
InternalCacheEntry implementation to store a L1 entry.Interceptor that handles L1 logic for non-transactional caches.
Segmented data container that also allows for non owned segments to be written to a temporary map (L1).
Interceptor that handles L1 logic for transactional caches.
A write synchronizer that allows for a single thread to run the L1 update while others can block until it is
completed.
Iterator implementation that will return all entries from the first iterator.
A delegating executor that lazily constructs and initializes the underlying executor.
A delegating executor that lazily constructs and initializes the underlying executor, since unused JDK executors
are expensive.
A delegating scheduled executor that lazily constructs and initializes the underlying scheduled executor, since
unused JDK executors are expensive.
Executes tasks in the given executor, but never has more than
maxConcurrentTasks tasks running at the same
time.Interface that denotes that the implementation can have listeners attached to it.
Class-level annotation used to annotate an object as being a valid cache listener.
Enumeration that defines when a listener event can be observed.
Defines simple listener invocation.
Used for registering various cache notifications.
Holder class for functional listener definitions.
Read-write listeners enable users to register listeners for cache
entry created, modified and removed events, and also register listeners
for any cache entry write events.
Read-write listener
Write listeners enable user to register listeners for any cache entry
write events that happen in either a read-write or write-only
functional map.
Write-only listener.
LoaderConfigurationBuilder is an interface which should be implemented by all cache loader builders
This is a marker interface to indicate that such commands will never be replicated and hence will not return any
valid command IDs.
The
LocalConfigurationStorage is responsible for applying on each node the configuration changes initiated
through the GlobalConfigurationManager and persist them unless they are
CacheContainerAdmin.AdminFlag.VOLATILE.Provide statistics of the local JVM instance.
Simulates a remote invocation on the local node.
Extends
CacheTopology with information about keys owned by the local node.Handles locally publishing entries from the cache.
LocalPublisherManager that publishes entries from the local node only.
Runs on every node and handles the communication with the
ClusterTopologyManager.Factory for ClusterTopologyManager implementations.
The
LocalTopologyManager implementation.Object that holds transaction's state on the node where it originated; as opposed to
RemoteTransaction.Invocation context to be used for locally originated transactions.
LocalTransaction implementation to be used with TransactionXaAdapter.A container for locks
Factory class that creates instances of
LockContainer.LockControlCommand is a command that enables distributed locking across infinispan nodes.
WARNING: Generated code!
Stream that allows for operation upon data solely with side effects by using
LockedStream.forEach(BiConsumer)
where the BiConsumer is invoked while guaranteeing that the entry being passed is properly locked for the
entire duration of the invocation.Lock Stream implementation that locks a key using the
LockManager before and after executing the various
code.Defines the local, in-VM locking and concurrency characteristics of the cache.
Defines the local, in-VM locking and concurrency characteristics of the cache.
Defines the locking modes that are available for transactional caches:
optimistic or pessimistic.
The listener for
LockPromise.An interface to deal with all aspects of acquiring and releasing locks for cache entries.
Factory class that creates instances of
LockManager.A promise returned by
InfinispanLock.The exception is thrown if a locks is released while waiting for it to be acquired.
The
InfinispanLock possible states.Infinispan's log abstraction layer on top of JBoss Logging.
Warning this class consists of generated code.
Warning this class consists of generated code.
Factory that creates
Log instances.This annotation is for internal use only!
LoggingAuditLogger.
Provides a
Log instance to use.A
LongStream that has additional methods to allow for Serializable instances.ManagerStatusResponse$___Marshaller_3342de565e5b7e8c162e25f13fb66b435492e161bd4e0f783e782f9e0e3c145f
WARNING: Generated code!
WARNING: Generated code!
Response collector supporting
JGroupsTransport.invokeRemotelyAsync(Collection, ReplicableCommand, ResponseMode, long, ResponseFilter, DeliverOrder).A wrapper for arrays of objects whose type is unknown until runtime.
WARNING: Generated code!
WARNING: Generated code!
A wrapper for a
Deque of objects whose type is unknown until runtime.WARNING: Generated code!
Defines an externally persisted entry.
Factory for
MarshallableEntry.A wrapper object that allows a generic
Serializable lambda to be marshalled by wrapping the contents
of a SerializedLambda object.WARNING: Generated code!
A wrapper for a
List of objects whose type is unknown until runtime.WARNING: Generated code!
A wrapper for Maps of user objects whose key/value type is unknown until runtime.
WARNING: Generated code!
A wrapper for interface implementations which can either be marshalled by the
GlobalMarshaller or the configured user marshaller if no internal marshaller exists for
the implementation.WARNING: Generated code!
A wrapper for a
Set of objects whose type is unknown until runtime.WARNING: Generated code!
WARNING: Generated code!
A wrapper message used by ProtoStream Marshallers to allow user objects to be marshalled/unmarshalled via the
MarshallableUserObject.Marshaller implementation, which delegates to the configured user marshaller in SerializationConfiguration if it exists.WARNING: Generated code!
A marshallable object containing serialized representations of cache values and metadata, that can be used to store
values, metadata and timestamps as a single entity.
A marshallable object that can be used by our internal store implementations to store values, metadata and timestamps.
WARNING: Generated code!
MarshallerFactory.
MarshallingTwoWayKey2StringMapper.
WARNING: Generated code!
JMX related component metadata, as expressed by
MBean, ManagedAttribute and ManagedOperation
annotations.Controls the memory storage configuration for the cache.
Controls the data container for the cache.
This annotation should be used on methods that need to be notified when the cache is used in a cluster and the
cluster topology experiences a merge event after a cluster split.
This event is passed in to any method annotated with
Merged.WARNING: Generated code!
Messages.
Warning this class consists of generated code.
This interface encapsulates metadata information that can be stored
alongside values in the cache.
Metadata builder
Marker interface for metadata aware cache entry.
A command that contains metadata information.
A form of
ImmortalCacheEntry that is MetadataAwareWARNING: Generated code!
A form of
ImmortalCacheValue that is MetadataAware.WARNING: Generated code!
A cache entry that is mortal and is
MetadataAwareWARNING: Generated code!
A mortal cache value, to correspond with
MetadataMortalCacheEntryWARNING: Generated code!
Utility method for Metadata classes.
A cache entry that is transient, i.e., it can be considered expired after a period of not being used, and
MetadataAwareWARNING: Generated code!
A transient cache value, to correspond with
TransientCacheEntry which is MetadataAwareWARNING: Generated code!
A form of
TransientMortalCacheEntry that stores MetadataWARNING: Generated code!
A form of
TransientMortalCacheValue that stores MetadataWARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
An easily extensible metadata parameter that's stored along with the value
in the the functional map.
Provides metadata parameter lookup capabilities using
Class as
lookup key.Read only metadata parameter representing a cached entry's created time
in milliseconds.
Writable metadata parameter representing a cached entry's generic version.
Read only metadata parameter representing a cached entry's last used time
in milliseconds.
Writable metadata parameter representing a cached entry's millisecond lifespan.
Non-writable parameter telling if the entry was loaded from a persistence tier
(
NonBlockingStore) or not.Abstract class for numeric long-based metadata parameter instances.
Writable metadata parameter representing a cached entry's millisecond
max idle time.
A parameter to tell if the creation timestamp should be updated for modified entries.
Writable
MetaParam instances are those that the user can provide
to be stored as part of the cache entry.Represents a
MetaParam collection.Metadata parameters backed internal metadata representation.
WARNING: Generated code!
Keeps a reference to the Micrometer MeterRegistry.
Produces instances of
MetricsCollector.A registry for metrics.
Utility methods for metrics.
Builder to inject an instance of
MeterRegistry.A configuration class to inject a custom
MeterRegistry instance.A
ConfigurationSerializer implementation to serialize MicrometerMeterRegistryConfiguration.WARNING: Generated code!
Thrown when members are missing after a cluster shutdown.
An interface that defines a
NonBlockingStore modificationA list of
WriteCommand for a transactionModificationsList contains a List<Modification>
This is a special interface that can mark a Function so that a user can know if the actual value will change
when the function is applied or not.
ModuleLifecycle is an API hook for delegating lifecycle events to Infinispan sub-modules.
Module metadata.
Store for component and module information.
A cache entry that is mortal.
WARNING: Generated code!
A mortal cache value, to correspond with
MortalCacheEntryWARNING: Generated code!
This command is used to send cluster events for multiple listeners on the same node
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
Invoke a sequence of sub-commands.
Request implementation that waits for responses from multiple target nodes.
A
RolePermissionMapper with the ability to add/remove roles at runtimeSimplified version of functional command used for read-only operations after transactional modifications.
Helper class for marshalling, also hiding implementations of
Mutation from the interface.An entry that can be safely copied when updates are made, to provide MVCC semantics
A factory that specifically knows how to create named executors.
A
SocketFactory which allows setting a callback to configure the sockets using a supplied name.Namespace.
NamespaceMappingParser.
Namespaces.
A DTO class used to represent the basic major, minor and patch values of an instance's
Version over the wire.WARNING: Generated code!
An empty implementation of
MetricsRegistry.Manager utility for non-blocking operations.
Local file-based cache store, optimized for write-through use with strong consistency guarantees
(ability to flush disk operations before returning from the store call)
The contract for defining how caches interface with external sources of data, such as databases or filesystems.
Enumeration defining the various characteristics of the underlying store to communicate what features it may
or may not support.
A Publisher that provides a stream of values and the segments to which those values map.
Executor Factory used for non blocking executors which utilizes
ThreadPoolExecutor internally.WARNING: Generated code!
WARNING: Generated code!
Handles x-site data backups for non-transactional caches.
Invocation Context container to be used for non-transactional caches.
Locking interceptor to be used for non-transactional caches.
Non-transactional interceptor used by distributed caches that support concurrent writes.
Context to be used for non transactional calls, both remote and local.
Interceptor used by IRAC for non transactional caches to handle the local site updates.
Interceptor to handle updates from remote sites.
A
PerCacheInboundInvocationHandler implementation for non-total order
caches.A no-op implementation of
BackupSender.A no-op implementation of
IracManager for cache without asynchronous remote site backups.No-op implementation for
IracTombstoneManager.A no-op implementation of
IracVersionGenerator for caches without asynchronous remote site backups.An empty implementation of
JGroupsMetricsManager.An
PendingLockManager implementation that does nothing.An empty
TakeOfflineManager implementation for caches which don't backup any data to remote sites.A no-op implementation of
XSiteEventsManager.An no-op implementation for
XSiteMetricsCollector.A no-op implementation of
XSiteStateProvider.A no-op implementation of
XSiteStateTransferManager.The interceptor in charge of firing off notifications to cache listeners
WARNING: Generated code!
WARNING: Generated code!
NullAuditLogger.
Numeric version
WARNING: Generated code!
Generates unique numeric versions for both local and clustered environments.
A
ConcurrentMap implementation that stores the keys and values off the JVM heap in native heap.Listener interface that is notified when certain operations occur for various memory addresses.
Factory that can create
InternalCacheEntry objects that use off-heap heap memory.Factory that can create CacheEntry instances from off-heap memory.
Allows for allocation of memory outside of the heap as well additional functionality surrounding it if
necessary.
SiteStatus implementation for offline sites.Keeps the state needed for knowing when a site needs to be taken offline.
SiteStatus implementation for online sites.Handles x-site data backups for optimistic transactional caches.
Locking interceptor to be used by optimistic transactional caches.
Interceptor used by IRAC for optimistic transactional caches to handle the local site updates.
WARNING: Generated code!
Outbound state transfer task.
An exception signalling that a command should be retried because a newer topology was seen during execution.
An implementation of
LocalConfigurationStorage which stores non-CacheContainerAdmin.AdminFlag.VOLATILEThis class holds statistics about a consistent hash.
An easily extensible parameter that allows functional map operations to be
tweaked.
Defines where is the command executed.
Normally the cache has to acquire locks during any write operation to guarantee
its correctness.
When a persistence store is attached to a cache, by default all write
operations, regardless of whether they are inserts, updates or removes,
are persisted to the store.
Defines how statistics are gathered for this command.
Parameter identifiers.
Factory for
KeyValueFilterConverter instances supporting
parameters.Internal class that encapsulates collection of parameters used to tweak
functional map operations.
WARNING: Generated code!
This class implements the parser for Infinispan/AS7/EAP/JDG schema files
ParserRegistry is a namespace-mapping-aware meta-parser which provides a way to delegate the
parsing of multi-namespace XML files to appropriate parsers, defined by the
ConfigurationParser interface.ParserScope indicates the configuration parser scope.
Cluster stream manager that also pays attention to partition status and properly closes iterators and throws
exceptions when the availability mode changes.
Controls how the cache handles partitioning and/or multiple node failures.
Controls how the cache handles partitioning and/or multiple node failures.
This annotation should be used on methods that need to be notified when the
AvailabilityMode in use by the
PartitionHandlingManager changes due to a change in cluster topology.The event passed in to methods annotated with
PartitionStatusChanged.A passivation manager
Passivation writer ignores any create/modify operations and only does removals.
Receive responses from multiple nodes, without checking that the responses are valid.
RPC to a single node, without any validity checks.
A listener that is invoked when
PendingLockPromise is ready.A manager that checks and waits for older topology transaction with conflicting keys.
A promise returned by
PendingLockManager.Interface to invoke when a
CacheRpcCommand is received from other node in the
local site.A lock container that creates and maintains a new lock per entry.
A permissive
AuthorizationManager.A record containing the
ConsistentHash restored from persistent state and any missing
UUIDs.Use this annotation on methods that require notification when the availability of the PersistenceManager changes.
Configuration for stores.
Configuration for cache stores.
Interface used to initialise the
PersistenceMarshallerImpl's SerializationContext
using the specified Pojos, Marshaller implementations and provided .proto schemas.WARNING: Generated code!
An exception thrown by a
NonBlockingStore implementation if there are problems
reading from a loader.Defines the logic for interacting with the chain of external storage.
The marshaller that is responsible serializing/deserializing objects which are to be persisted.
A Protostream based
PersistenceMarshaller implementation that is responsible
for marshalling/unmarshalling objects which are to be persisted.Persistence Utility that is useful for internal classes.
PersistentUUIDManager maintains a mapping of
UUIDs present in the clusterImplementation of the
PersistentUUIDManager interfaceHandles x-site data backups for pessimistic transactional caches.
Locking interceptor to be used by pessimistic caches.
Interceptor used by IRAC for pessimistic transactional caches to handle the local site updates.
This class is here solely for the purpose of encapsulating the
PmemUtil class so we do not load it unless
necessary, allowing this to be an optional dependency.A Filter that only allows post events to be accepted.
A
XSiteEntryMergePolicy implementation that chooses a non-null entry.A
XSiteEntryMergePolicy implementation that chooses a null entry.Separate the preload into its own component
Command corresponding to the 1st phase of 2PC.
WARNING: Generated code!
Default implementation for RecoveryIterator.
A
ValidResponse used by Optimistic Transactions.WARNING: Generated code!
A
Collector implementation that only waits for the primary owner.Entry Size calculator that returns an approximation of how much various primitives, primitive wrappers, Strings, and
arrays
PrincipalRoleMapper.
Deprecated, for removal: This API element is subject to removal in a future version.
since 14.0.
An internal configuration.
A
Builder implementation of PrivateGlobalConfiguration.A
ConfigurationSerializer implementation for PrivateGlobalConfiguration.A class to store internal metadata.
WARNING: Generated code!
Concrete implementation of
MetricsRegistry.Concrete implementation of
AbstractMetricsRegistry.Extracts the configuration into flat key-value property structure by reflection.
Performs conversions between application/x-protostream and commons formats.
Handler for holding publisher results between requests of data
Factory that allows creation of a
LocalPublisherManager or ClusterPublisherManager based on the provided
configuration.Static factory method class to provide various reducers and finalizers for use with distributed Publisher.
Static factory method class to provide various transformers for use with distributed Publisher.
Implements functionality defined by
BasicCache.put(Object, Object)WARNING: Generated code!
A
BackupWriteCommand implementation for PutMapCommand.WARNING: Generated code!
A command writing multiple key/value pairs with the same metadata.
WARNING: Generated code!
Configures query options and defaults
Invocation stage representing a computation that may or may not be done yet.
This interface describes methods needed for a segment listener that is used when iterating over the current
events and be able to queue them properly
A channel abstraction to invoke commands on the RAFT channel.
A configuration object to configure
RaftChannel.Use this class to create and register
RaftStateMachine.A state machine interface.
Utility methods for jgroups-raft
Compute the version prefix to be used by
NumericVersionGenerator in clustered caches.A wrapper around a cached entry that encapsulates read committed semantics when writes are initiated, committed or
rolled back.
WARNING: Generated code!
WARNING: Generated code!
Read-only map implementation.
Set implementation that shows a read only view of the provided set by only allowing
entries that map to a given segment using the provided consistent hash.
Iterator implementation that shows a read only view of the provided iterator by only
allowing values that map to a given segment using the provided consistent hash.
Iterator implementation that shows a read only view of the provided iterator by only
allowing values that map to a given segment using the provided consistent hash.
Iterator implementation that shows a read only view of the provided iterator by only
allowing values that map to a given segment using the provided consistent hash.
Map implementation that shows a read only view of the provided entry by only allowing
entries whose key maps to a given segment using the provided consistent hash.
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
Read-write map implementation.
ReadWriteSnapshotView$___Marshaller_4d4d73378f0d2913eabc7c3a475a6a3e152715044677347617448c0ea2580fd4
WARNING: Generated code!
WARNING: Generated code!
An interface that allows the
PerCacheInboundInvocationHandler to check
when this action is ready.A member is confirming that it has finished a topology change during rebalance.
WARNING: Generated code!
Enable or Disable rebalancing.
WARNING: Generated code!
The coordinator is starting a rebalance operation.
RebalanceStartCommand$___Marshaller_a55e90983178a4bb7d328b1e98d6656ada672388b0d09519acbe54e377b48c7f
WARNING: Generated code!
Query the rebalancing status.
WARNING: Generated code!
RebalancingStatus.
A thread gate, that uses an
AbstractQueuedSynchronizer.Admin utility class for allowing management of in-doubt transactions (e.g. transactions for which the
originator node crashed after prepare).
Extends
LocalXaTransaction and adds recovery related information.Extends
RemoteTransaction and adds recovery related information and functionality.Base interface for transactions that are holders of recovery information.
Transaction table that delegates prepared transaction's management to the
RecoveryManager.Defines recovery configuration for the cache.
Defines recovery configuration for the cache.
This makes sure that only xids pertaining to a certain cache are being returned when needed.
RecoveryManager is the component responsible with managing recovery related information and the functionality
associated with it.
Stateful structure allowing prepared-tx retrieval in a batch-oriented manner, as required by
XAResource.recover(int).Factory for RecoveryManager.
Default implementation for
RecoveryManagerWARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
A simple regular expression-based name rewriter.
A listener that installed locally on each node when a cluster listener is installed on a given node.
Represents an application-level exception originating in a remote node.
Return the first successful response for a staggered remote get, used in dist mode.
Simple interface to extract all the keys that may need to be locked.
This is a metadata type used by scattered cache during state transfer.
WARNING: Generated code!
Cross-Site state transfer status and collector
Defines the state of a remotely originated transaction.
Context to be used for transaction that originated remotely.
Listener that is notified when a remote value is looked up
Deprecated.
Users should use
RemovableCloseableIterator insteadDeprecated.
Users should use
RemovableIterator insteadRepresents a
NonBlockingStore.delete(int, Object) modificationWARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
Removes an entry that is expired from memory
WARNING: Generated code!
WARNING: Generated code!
removeListenerAsync action
WARNING: Generated code!
WARNING: Generated code!
An extension of
ReadCommittedEntry that provides Repeatable Read semanticsWARNING: Generated code!
The core of the command-based cache framework.
Replicable Command that runs the given Function passing the
EmbeddedCacheManager as an argumentWARNING: Generated code!
Replicable Command that runs the given Runnable
WARNING: Generated code!
Special implementation of
ConsistentHash for replicated caches.WARNING: Generated code!
Factory for ReplicatedConsistentHash.
WARNING: Generated code!
Interface responsible to send back the return value to the sender.
A remote command invocation request.
A tracker for synchronous requests.
Uniquely identifies an operation or transaction within the cluster.
WARNING: Generated code!
This class was copied from JGroups and adapted.
Implementation of
HashFunctionPartitioner using CRC16 for use with RESP.A response to be sent back to a remote caller
A representation of a request's responses.
A mechanism of filtering RPC responses.
A component that generates responses as is expected by different cache setups
Creates a ResponseGenerator
Represents different handling mechanisms when dealing with remote command responses.
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
Key provider that relies on
Random's distribution to generate keys.A role to permission mapping.
Maps roles to permissions
WARNING: Generated code!
Command corresponding to a transaction rollback.
WARNING: Generated code!
RollingUpgradeManager handles the synchronization of data between Infinispan
clusters when performing rolling upgrades.
Thrown when an RPC problem occurred on the caller.
Provides a mechanism for communicating with other caches in the cluster, by formatting and passing requests down to
the registered
Transport.A factory for the RpcManager
This component really is just a wrapper around a
Transport implementation,
and is used to set up the transport and provide lifecycle and dependency hooks into external transport
implementations.Classes that wraps all the configuration parameters to configure a remote invocation.
Static factory class that provides methods to obtain commonly used instances for interoperation between RxJava
and standard JRE.
A scheduled CompletionStage that may be cancelled if it has not been started yet.
Used to configure and create scheduled executors
Configures executor factory.
Schema.
ScopedPersistentState represents state which needs to be persisted, scoped by name (e.g. the cache name).
ScopedPersistentStateImpl.
Key for scoped entries in the ClusterConfigurationManager state cache
WARNING: Generated code!
A filter for
ScopedState that allows listeners of the global state cache to choose events by scope.WARNING: Generated code!
Copy of
Scopes to avoid a runtime dependency on the annotations module.SecureCache.
SecureCacheImpl.
Mark a method as secure.
Security.
SecurityConfiguration.
SecurityConfigurationBuilder.
Terminal stream operation that is aware of segments being lost.
This is the same as
SegmentPublisherSupplier except that it also allows listening for when a segment is
lost.Notification that can also contains lost segments.
A
Publisher that also allows receiving segment completion information if desired.Wrapper around an element returned that can either be a value or a segment completion.
WARNING: Generated code!
Interface to be implemented when the command can define a single segment for its operation.
Executes tasks in the given executor, but never has more than
maxConcurrentTasks tasks running at the same time.This is a functional interface that is the same as a
BiConsumer except that it must also be
SerializableThis is a functional interface that is the same as a
BiFunction except that it must also be
SerializableThis is a functional interface that is the same as a
BinaryOperator except that it must also be
SerializableThis is a functional interface that is the same as a
Callable except that it must also be
SerializableThis is a functional interface that is the same as a
Comparator except that it must also be
SerializableThis is a functional interface that is the same as a
Consumer except that it must also be
SerializableThis is a functional interface that is the same as a
DoubleBinaryOperator except that it must also be
SerializableThis is a functional interface that is the same as a
DoubleConsumer except that it must also be
SerializableThis is a functional interface that is the same as a
DoubleFunction except that it must also be
SerializableThis is a functional interface that is the same as a
DoublePredicate except that it must also be
SerializableThis is a functional interface that is the same as a
DoubleToIntFunction except that it must also be
SerializableThis is a functional interface that is the same as a
DoubleToLongFunction except that it must also be
SerializableThis is a functional interface that is the same as a
DoubleUnaryOperator except that it must also be
SerializableThis is a functional interface that is the same as a
Function except that it must also be
SerializableThis is a functional interface that is the same as a
IntBinaryOperator except that it must also be
SerializableThis is a functional interface that is the same as a
IntConsumer except that it must also be
SerializableThis is a functional interface that is the same as a
IntFunction except that it must also be
SerializableThis is a functional interface that is the same as a
IntPredicate except that it must also be
SerializableThis is a functional interface that is the same as a
IntToDoubleFunction except that it must also be
SerializableThis is a functional interface that is the same as a
IntToLongFunction except that it must also be
SerializableThis is a functional interface that is the same as a
IntUnaryOperator except that it must also be
SerializableThis is a functional interface that is the same as a
LongBinaryOperator except that it must also be
SerializableThis is a functional interface that is the same as a
LongConsumer except that it must also be
SerializableThis is a functional interface that is the same as a
LongFunction except that it must also be
SerializableThis is a functional interface that is the same as a
LongPredicate except that it must also be
SerializableThis is a functional interface that is the same as a
LongToDoubleFunction except that it must also be
SerializableThis is a functional interface that is the same as a
LongToIntFunction except that it must also be
SerializableThis is a functional interface that is the same as a
LongUnaryOperator except that it must also be
SerializableThis is a functional interface that is the same as a
ObjDoubleConsumer except that it must also be
SerializableThis is a functional interface that is the same as a
ObjIntConsumer except that it must also be
SerializableThis is a functional interface that is the same as a
ObjLongConsumer except that it must also be
SerializableThis is a functional interface that is the same as a
Predicate except that it must also be
SerializableThis is a functional interface that is the same as a
Runnable except that it must also be
SerializableThis is a functional interface that is the same as a
Supplier except that it must also be
SerializableThis is a functional interface that is the same as a
ToDoubleFunction except that it must also be
SerializableThis is a functional interface that is the same as a
ToIntFunction except that it must also be
SerializableThis is a functional interface that is the same as a
ToLongFunction except that it must also be
SerializableConfigures serialization and marshalling settings.
Manages
SerializationContext across modules for use by various components.SerializedWith, specifies the
ConfigurationSerializer to use to serialize the annotated classSetInternalCacheValue$___Marshaller_b3868a816f8631c02868f5805d93408c3bf4c20cf90fc65d7c1f36a6b7d3c7e0
WARNING: Generated code!
A set that maps another one to a new one of a possibly different type.
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
Behavior of the JVM shutdown hook registered by the cache
Invocation stage representing a computation that may or may not be done yet.
Simple local cache without interceptor stack.
A simple versioning scheme that is cluster-aware
WARNING: Generated code!
A version generator implementation for SimpleClusteredVersions
A
ReadOnlyMapImpl that works with a simple cache.A
ReadWriteMapImpl that works with a simple cache.A
WriteOnlyMapImpl that works with a simple cache.A filesystem-based implementation of a
NonBlockingStore.Defines the configuration for the single file cache store.
Single file cache store configuration builder.
A single key
BackupWriteCommand for single key non-functional commands.WARNING: Generated code!
A single key
BackupWriteCommand for single key functional commands.WARNING: Generated code!
Response collector for a single response.
KeyPartitioner that always returns 0 for a given segment.
Request implementation that waits for a response from a single target site.
Request implementation that waits for a response from a single target node.
Response collector supporting
JGroupsTransport.invokeRemotelyAsync(Collection, ReplicableCommand, ResponseMode, long, ResponseFilter, DeliverOrder).RPC command to replicate cache operations (such as put, remove, replace, etc.) to the backup site.
SingleXSiteRpcCommand$___Marshaller_966d8ea14d4eb9de9a18bd4c2a890c08e8d2dd3e7c12168a2cfacef56b350328
WARNING: Generated code!
It stores the entry value and
Metadata for a specific site.The site state.
A site status.
A simple interface that is invoked by
OfflineStatus when a particular site changes its
status to online/offline.This event is passed in to any method annotated with
SiteViewChanged.A
XSiteResponse which is competed with a SuspectException.This annotation should be used on methods that need to be notified when the cross-site view changes (sites connects
or disconnects).
Factory for creating size calculator used to estimate size of objects
Command to calculate the size of the cache
WARNING: Generated code!
WARNING: Generated code!
Encapsulates a chunk of cache entries that belong to the same segment.
WARNING: Generated code!
Handles inbound state transfers.
StateConsumer implementation.Handles outbound state transfers.
StateProvider implementation.This command is used by a StateProvider to push cache entries to a StateConsumer.
WARNING: Generated code!
Cancel state transfer.
WARNING: Generated code!
Empty marker interface used to indicate that a command relates to state transfer.
Configures how state is retrieved when a new cache joins the cluster.
Configures how state is transferred when a cache joins or leaves the cluster.
Get the registered cluster listeners.
WARNING: Generated code!
Get transactions for the specified segments.
WARNING: Generated code!
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.
We use the state transfer lock for three different things:
We don't want to execute a command until we have the transaction table for that topology id.
StateTransferLock implementation.A component that manages the state transfer when the topology of the cluster changes.
StateTransferManager implementation.Start state transfer.
WARNING: Generated code!
Cross-site state transfer status.
Determines whether cache statistics are gathered.
Determines whether cache statistics are gathered.
Stats.
Wraps existing
AdvancedCache to collect statisticsResponses for functional commands that allow to record statistics.
WARNING: Generated code!
StatsImpl.
Key/value storage information (storage media type and wrapping).
Enumeration defining the various storage types for the data container.
Modification representing
NonBlockingStore.write(int, MarshallableEntry).StoreConfiguration contains generic configuration elements available to all the stores.
LoaderConfigurationBuilder is an interface which should be implemented by all cache loader builders
An exception thrown by the
PersistenceManager if one or more
stores are unavailable when a cache operation is attempted.Static factory class containing methods that will provide marshallable instances for very common use cases.
An hash function for stripping.
Holder for stamped locks that provides ability to retrieve them by offset and hashCode
Note that locks protect entries
A lock container used with lock stripping.
SubjectACL.
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
SuccessfulMapResponse$___Marshaller_839841d6bd1a180edd9621f53e11a2c777e5a0f1629c0e653dc933080c62d333
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
SuccessfulObjResponse$___Marshaller_1dfba76e16279afd4bc34e49a361c0c42f9ab966f7390adf6fd81bb806deee4e
WARNING: Generated code!
A successful response
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
Thrown when a member is suspected during remote method invocation
ConsistentHashFactory implementation
that guarantees that multiple caches with the same members will
have the same consistent hash (unlike DefaultConsistentHashFactory).WARNING: Generated code!
Synchronization implementation for integrating with the TM.LocalTransaction implementation to be used with SynchronizationAdapter.A
XSiteStateProviderState for synchronous cross-site replication state transfer.SyncConsistentHashFactory adapted for replicated caches, so that the primary owner of a key
is the same in replicated and distributed caches.WARNING: Generated code!
It keeps tracks of cross-site requests to take sites offline when certain failures conditions happen.
The return value of
TakeOfflineManager.takeSiteOffline(String).Performs migration operations on the target server or cluster of servers
Table holding the entry positions in log before these are persisted to the index.
Interface describing an operation that is a terminal one that doesn't track keys.
WARNING: Generated code!
WARNING: Generated code!
Some of the commands sent over the wire can only be honored by the receiver if the topology of the cluster at
delivery time is still 'compatible' with the topology in place at send time (eg. a 'get' command cannot execute
on a node that is no longer owner after state transfer took place).
Default topology-aware consistent hash factory implementation.
WARNING: Generated code!
A
ConsistentHashFactory implementation that guarantees caches
with the same members have the same consistent hash and also tries to distribute segments based on the
topology information in TransportConfiguration.WARNING: Generated code!
This annotation should be used on methods that need to be notified when the
ConsistentHash implementation
in use by the DistributionManager changes due to a change in cluster topology.The event passed in to methods annotated with
TopologyChanged.This class holds the topology hierarchy of a cache's members and estimates for owned segments.
Base class for locations.
The version stored per
CacheEntry for IRAC.WARNING: Generated code!
The cluster topology is a tree with five levels: the entire cluster, sites, racks, machines, and
individual nodes.
It checks or waits until the required topology is installed.
Coordinator to member:
The coordinator is updating the consistent hash.
TopologyUpdateCommand$___Marshaller_9528d6bc5cb25ad5c0eb3b73c4ac6fa10cedce83f379668824344f1e284e4433
WARNING: Generated code!
Update the stable topology.
WARNING: Generated code!
This command updates a cache entry's last access timestamp.
WARNING: Generated code!
Control how the timestamp of read keys are updated on all the key owners in a cluster.
An event subtype that includes a transaction context - if one exists - as well as a boolean as to whether the call
originated locally or remotely.
Interceptor that prevents the cache from inserting too many entries over a configured maximum amount.
Invocation context to be used for transactional caches.
Simple interface to extract all the keys that may need to be locked for transactional commands.
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.
An transaction boundary command that allows the retrieval of an attached
GlobalTransactionThis annotation should be used on methods that need to be notified when the cache is called to participate in a
transaction and the transaction completes, either with a commit or a rollback.
This event is passed in to any method annotated with
TransactionCompleted.Defines transactional (JTA) characteristics of the cache.
Defines transactional (JTA) characteristics of the cache.
Coordinates transaction prepare/commits as received from the
TransactionManager.Factory for transaction related state.
A representation of a transaction that is suitable for transferring between a StateProvider and a StateConsumer
running on different members of the same cache.
WARNING: Generated code!
Uses a number of mechanisms to retrieve a transaction manager.
Transaction mode
Enumeration containing the available transaction modes for a cache.
An interface to check if the transaction originator is left or not.
This annotation should be used on methods that need to be notified when the cache is called to participate in a
transaction and registers a
Synchronization with a registered TransactionManager.This event is passed in to any method annotated with
TransactionRegistered.Factory for the TransactionSynchronizationRegistry
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.
Repository for
RemoteTransaction and TransactionXaAdapters (locally
originated transactions).Interface that allows to fetch the
GlobalTransaction associated to local or
remote transactions.Factory for
TransactionTable objects.This acts both as an local
CacheTransaction and implementor of an XAResource that will be called by tx manager on various tx stages.A cache entry that is transient, i.e., it can be considered expired after a period of not being used.
WARNING: Generated code!
A transient cache value, to correspond with
TransientCacheEntryWARNING: Generated code!
A cache entry that is both transient and mortal.
WARNING: Generated code!
A transient, mortal cache value to correspond with
TransientMortalCacheEntryWARNING: Generated code!
An interface that provides a communication link with remote caches.
Configures the transport used for network communications across the cluster.
Factory for Transport implementations.
Unsorted traversable stream for sequential and aggregating operations.
Non-transactional interceptor used by distributed caches that supports concurrent writes.
Some utility functions for
TriangleDistributionInterceptor.An
Action that checks if the command is the next to be executed.It manages the order of updates from the primary owner to backup owner.
A
PerCacheInboundInvocationHandler implementation for non-transactional and distributed caches that uses the
triangle algorithm.Represents an operation that accepts three input arguments and returns no
result.
Represents a predicate (boolean-valued function) of three arguments.
Performs conversions where there is no direct transcoder, but there are two transcoders available:
one from source media type to application/x-java-object
one from application/x-java-object to the destination media type
Extends
Key2StringMapper and allows a bidirectional transformation between keys and Strings.Command for removing recovery related information from the cluster.
WARNING: Generated code!
Handles the distribution of the transactional caches.
Interceptor in charge with handling transaction related operations, e.g enlisting cache as an transaction
participant, propagating remotely initiated changes.
Interface defining additional functionality for invocation contexts that propagate within a transaction's scope.
Locked Stream that is designed for transactions.
A
PerCacheInboundInvocationHandler implementation for non-total order caches.WARNING: Generated code!
TxReadOnlyManyCommand$___Marshaller_5b6ee6ba6f8c58556fb6d66baf4d22f2fb8275d962ee7e8262eea96ac7eb3a95
WARNING: Generated code!
Defines the action taken when a dangling lock file is found in the persistent global state, signifying an
unclean shutdown of the node (usually because of a crash or an external termination).
UndefineConfigurationAction.
Memory allocator that just allocates memory directly using
Unsafe.Controls certain tuning parameters that may break some of Infinispan's public API contracts in
exchange for better performance in some cases.
Controls certain tuning parameters that may break some of Infinispan's public API contracts in exchange for better
performance in some cases.
An unsuccessful response
WARNING: Generated code!
Exception thrown by certain cache stores when one tries to persist an entry with an unsupported key type.
Exception thrown when an action is attempted before all members of the cluster support it.
An unsure response - used with Dist - essentially asks the caller to check the next response from the next node since
the sender is in a state of flux (probably in the middle of rebalancing)
WARNING: Generated code!
Thrown when client's code passed as a labda expression in commands such as
ComputeIfAbsentCommand
raises a exception.WARNING: Generated code!
A valid response
Base class for response collectors, splitting responses into valid responses, exception responses, and target missing.
A policy for determining if a write command should be executed based on the current value in the cache.
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.WARNING: Generated code!
A version of the
TxDistributionInterceptor that adds logic to handling prepares when entries are
versioned.Interceptor in charge with wrapping entries and add them in caller's context.
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).WARNING: Generated code!
A version of RepeatableReadEntry that can perform write-skew checks during prepare.
WARNING: Generated code!
WARNING: Generated code!
Generates versions
Version generator component factory.
The various versioning schemes supported
Interceptor installed when compatiblity is enabled.
This annotation should be used on methods that need to be notified when the cache is used in a cluster and the
cluster topology changes (i.e., a member joins or leaves the cluster).
This event is passed in to any method annotated with
ViewChanged.A type of command that can accept
Visitors, such as DDAsyncInterceptor.Response collector that discards successful responses and returns
null.An implementation of
LocalConfigurationStorage which does only supports
CacheContainerAdmin.AdminFlag.VOLATILE operationsWildFly transaction client lookup (WildFly 11 and later).
Used by
ComponentAccessor implementations for retrieving a component based on name and class.An executor that works within the current thread.
Executor factory that creates WithinThreadExecutor.
This class is an implementation for
TwoWayKey2StringMapper that supports both primitives
and WrappedByteArrays.Size calculator that supports a
WrappedByteArray by adding its size and the underlying byte[].A utility class for common actions related to ProtoStream
WrappedMessage.WARNING: Generated code!
WARNING: Generated code!
A writeable cache collection mapper that also has constant time operations for things such as
Collection.contains(Object) if the underlying Collection does.A writeable cache set mapper that also has constant time operations for things such as
Collection.contains(Object) if the underlying Set does.A command that modifies the cache in some way
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
WARNING: Generated code!
Write-only map implementation.
Thrown when a write skew is detected
WARNING: Generated code!
Encapsulates write skew logic in maintaining version maps, etc.
WARNING: Generated code!
TransactionTable to be used with TransactionXaAdapter.A Managed bean exposing system administration operations for Cross-Site replication functionality (cache scope only)
Amend a sites offline status.
WARNING: Generated code!
A listener to be notified when an asynchronous cross-site request is completed.
A
CacheRpcCommand to check the remote site status and state transfer mode in the local cluster.WARNING: Generated code!
Maps caches from remote site to local caches.
A
XSiteRequest which is associated to a cache.An interface to resolve conflicts for asynchronous cross-site replication.
A factory for
XSiteEntryMergePolicy.Represents an event related to cross-site.
WARNING: Generated code!
A collector of events to be sent to the remote site.
A manager class that handles the
XSiteEvent from local and remote sites.Default implementation of
XSiteEventsManager.Types of
XSiteEvent.Sends
XSiteEvent list from a local site node.WARNING: Generated code!
An alias with the provided implementation of
XSiteEntryMergePolicy.Collects metrics about cross-site replication operations.
Caches the site name
String and ByteString instances.Sends a
XSiteEvent list from a remote site.WARNING: Generated code!
It represents a cross-site request.
An extension to
CompletionStage with XSiteResponse.whenCompleted(XSiteResponseCompleted).Default implementation of
XSiteResponse.A
CacheRpcCommand that sets the XSiteStateTransferMode cluster-wide.WARNING: Generated code!
Represents the state of a single key to be sent to a backup site.
WARNING: Generated code!
It contains the logic needed to consume the state sent from other site.
It contains the logic needed to consume the state sent from other site.
It contains the logic to send state to another site.
It contains the logic to send state to another site.
Interface to store the information about a single remote site for
XSiteStateProviderImpl.Wraps the state to be sent to another site
XSiteStatePushCommand$___Marshaller_1d968f7f7e20559569deffe56774cefaf1616a88d37f6aaad2f409b2de3089df
WARNING: Generated code!
Wraps the state to be sent to another site.
XSiteStatePushRequest$___Marshaller_d0f9dc43456a1b0de8edb8f0fecf350e4393685f4b04a5929bd13e4f0452c8a5
WARNING: Generated code!
Sends local cluster state to remote site.
Cancel sending XSite state.
WARNING: Generated code!
Clear XSite state transfer status.
WARNING: Generated code!
It collects the acknowledgements sent from local site member to signal the ending of the state sent.
Configuration needed for State Transfer between different sites.
Configuration Builder to configure the state transfer between sites.
Controls the start and stop of receiving the cross-site state transfer.
WARNING: Generated code!
Finish receiving XSite state.
WARNING: Generated code!
Finish sending XSite state.
WARNING: Generated code!
It manages the state transfer between sites.
XSiteStateTransferManager implementation.Cross site state transfer mode.
Restart sending XSite state.
WARNING: Generated code!
Start receiving XSite state.
WARNING: Generated code!
Start send XSite state.
WARNING: Generated code!
Get XSite state transfer status.
WARNING: Generated code!
BasicComponentRegistryinstead.