Uses of Annotation Type
org.infinispan.commons.util.Experimental
Package
Description
This is the core of Infinispan, a distributed, transactional, highly scalable data grid
platform.
Functional API package
Infinispan is designed around a set of interceptors around a data container.
Metadata interfaces
MultimapCache API.
Embedded Multimap Cache.
Cache
-specific notifications and eventing filtering classes.The Persistence SPI.
Transports handle the low-level networking, used by the remoting components.
General utilities that are not specific to Infinispan, including string parsing helpers, reflection tools and
collections and containers designed to supplement the JDK-provided containers.
-
Uses of Experimental in org.infinispan
Modifier and TypeMethodDescriptionLockedStream.invokeAll
(BiFunction<Cache<K, V>, ? super CacheEntry<K, V>, R> biFunction) Performs a BiFunction for each element of this stream on the primary owner of each entry returning a value.LockedStream.invokeAll
(SerializableBiFunction<Cache<K, V>, ? super CacheEntry<K, V>, R> biFunction) Same asLockedStream.invokeAll(BiFunction)
except that the BiFunction must also implementSerializable
default org.reactivestreams.Publisher<E>
CacheCollection.localPublisher
(int segment) Returns a publisher that will publish all elements that map to the given segment.default org.reactivestreams.Publisher<E>
CacheCollection.localPublisher
(IntSet segments) Returns a publisher that will publish all elements that map to the given segment. -
Uses of Experimental in org.infinispan.client.hotrod.multimap
-
Uses of Experimental in org.infinispan.factories.impl
Modifier and TypeMethodDescriptionBasicComponentRegistry.getMBeanMetadata
(String className) BasicComponentRegistry.getRegisteredComponents()
Runconsumer
for each registered component in the current scope.boolean
BasicComponentRegistry.hasComponentAccessor
(String componentClassName) Check if a component accessor has been registered for classcomponentClassName
<T> ComponentRef<T>
BasicComponentRegistry.lazyGetComponent
(Class<T> componentType) Looks up a component namedname
in the registry, or registers it if necessary.void
BasicComponentRegistry.replaceComponent
(String componentName, Object newInstance, boolean manageLifecycle) Replace an existing component.void
BasicComponentRegistry.rewire()
Rewire all the injections after a component was replaced withBasicComponentRegistry.replaceComponent(String, Object, boolean)
. -
Uses of Experimental in org.infinispan.functional
Modifier and TypeClassDescriptionfinal class
Entry views expose cached entry information to the user.static interface
Expose read-only information about a cache entry potentially associated with a key in the functional map.static interface
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.static interface
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.interface
FunctionalMap<K,
V> 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.static interface
Exposes read-only operations that can be executed against the functional map.static interface
Exposes read-write operations that can be executed against the functional map.static interface
Exposes write-only operations that can be executed against the functional map.final class
Holder class for functional listener definitions.static interface
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.static interface
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.static interface
Write-only listener.interface
MetaParam<T>
An easily extensible metadata parameter that's stored along with the value in the the functional map.static interface
Provides metadata parameter lookup capabilities usingClass
as lookup key.static class
static final class
Read only metadata parameter representing a cached entry's created time in milliseconds.static class
Writable metadata parameter representing a cached entry's generic version.static final class
Read only metadata parameter representing a cached entry's last used time in milliseconds.static final class
Writable metadata parameter representing a cached entry's millisecond lifespan.static final class
Non-writable parameter telling if the entry was loaded from a persistence tier (CacheLoader
) or not.static class
Abstract class for numeric long-based metadata parameter instances.static final class
Writable metadata parameter representing a cached entry's millisecond max idle time.static final class
A parameter to tell if the creation timestamp should be updated for modified entries.static interface
WritableMetaParam
instances are those that the user can provide to be stored as part of the cache entry.interface
Param<P>
An easily extensible parameter that allows functional map operations to be tweaked.static enum
Defines where is the command executed.static enum
Normally the cache has to acquire locks during any write operation to guarantee its correctness.static enum
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.static enum
static enum
Defines how statistics are gathered for this command.final class
Parameter identifiers.interface
Traversable<T>
Unsorted traversable stream for sequential and aggregating operations. -
Uses of Experimental in org.infinispan.functional.impl
Modifier and TypeClassDescriptionfinal class
Entry views implementation class holder.final class
FunctionalMapImpl<K,
V> Functional map implementation.interface
FunctionalNotifier<K,
V> Listener notifier.final class
final class
Represents aMetaParam
collection.final class
Metadata parameters backed internal metadata representation.final class
Internal class that encapsulates collection of parameters used to tweak functional map operations.final class
ReadOnlyMapImpl<K,
V> Read-only map implementation.final class
ReadWriteMapImpl<K,
V> Read-write map implementation.final class
WriteOnlyMapImpl<K,
V> Write-only map implementation. -
Uses of Experimental in org.infinispan.interceptors
Modifier and TypeInterfaceDescriptioninterface
Interface for sequential interceptors.interface
Interceptor chain usingAsyncInterceptor
s.class
Base class for an interceptor in the new asynchronous invocation chain. -
Uses of Experimental in org.infinispan.metadata
Modifier and TypeMethodDescriptiondefault Metadata.Builder
Metadata.Builder.updateCreationTimestamp
(boolean enabled) Sets how the creation timestamp is updated.default boolean
Metadata.updateCreationTimestamp()
Returns if the creation timestamp is updated when an entry is modified. -
Uses of Experimental in org.infinispan.multimap.api
Modifier and TypeInterfaceDescriptioninterface
BasicMultimapCache<K,
V> BasicMultimapCache
provides the common API for the two different types of multimap caches that Infinispan provides: embedded and remote. -
Uses of Experimental in org.infinispan.multimap.api.embedded
Modifier and TypeInterfaceDescriptioninterface
MultimapCache<K,
V> Embedded version of MultimapCache.interface
MultimapCacheManager<K,
V> -
Uses of Experimental in org.infinispan.notifications.cachelistener.filter
-
Uses of Experimental in org.infinispan.persistence.spi
Modifier and TypeInterfaceDescriptioninterface
Deprecated, for removal: This API element is subject to removal in a future version.interface
NonBlockingStore<K,
V> The contract for defining how caches interface with external sources of data, such as databases or filesystems.Modifier and TypeMethodDescriptiondefault boolean
NonBlockingStore.ignoreCommandWithFlags
(long commandFlags) Some stores may not want to perform operations based on if a command has certain flags. -
Uses of Experimental in org.infinispan.remoting.transport
Modifier and TypeInterfaceDescriptioninterface
A representation of a request's responses.class
class
Base class for response collectors, splitting responses into valid responses, exception responses, and target missing.class
Modifier and TypeMethodDescriptiondefault <T> CompletionStage<T>
Transport.invokeCommand
(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit) Invoke a command on a collection of node and pass the responses to aResponseCollector
.default <T> CompletionStage<T>
Transport.invokeCommand
(Address target, ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit) Invoke a command on a single node and pass the response to aResponseCollector
.default <T> CompletionStage<T>
Transport.invokeCommandOnAll
(Collection<Address> requiredTargets, ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit) Invoke a command on all the nodes in the cluster and pass the responses to aResponseCollector
.default <T> CompletionStage<T>
Transport.invokeCommandOnAll
(ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit) Invoke a command on all the nodes in the cluster and pass the responses to aResponseCollector
.default <T> CompletionStage<T>
Transport.invokeCommands
(Collection<Address> targets, Function<Address, ReplicableCommand> commandGenerator, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit timeUnit) Invoke different commands on a collection of nodes and pass the responses to aResponseCollector
.default <T> CompletionStage<T>
Transport.invokeCommandStaggered
(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder, long timeout, TimeUnit unit) Invoke a command on a collection of nodes and pass the responses to aResponseCollector
.default void
Transport.sendToAll
(ReplicableCommand rpcCommand, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder) Asynchronously sends theReplicableCommand
to the entire cluster. -
Uses of Experimental in org.infinispan.remoting.transport.impl
Modifier and TypeClassDescriptionclass
-
Uses of Experimental in org.infinispan.util
Modifier and TypeInterfaceDescriptioninterface
Interface to implement an exponential back-off algorithm that retries the request based on the result of the remote operation.
NonBlockingStore