Uses of Class
org.infinispan.commons.util.Experimental
-
Packages that use Experimental Package Description org.infinispan This is the core of Infinispan, a distributed, transactional, highly scalable data grid platform.org.infinispan.functional Functional API packageorg.infinispan.interceptors Infinispan is designed around a set of interceptors around a data container.org.infinispan.lock Embedded Clustered Locks.org.infinispan.lock.api Clustered Locks API.org.infinispan.multimap.api MultimapCache API.org.infinispan.multimap.api.embedded Embedded Multimap Cache.org.infinispan.notifications.cachelistener.filter Cache
-specific notifications and eventing filtering classes.org.infinispan.persistence.spi The Persistence SPI.org.infinispan.remoting.rpc Remote Procedure Call (RPC) interfaces and components used to invoke remote methods on cache instances.org.infinispan.remoting.transport Transports handle the low-level networking, used by the remoting components. -
Packages with annotations of type Experimental Package Description org.infinispan.functional Functional API package -
-
Uses of Experimental in org.infinispan
Methods in org.infinispan with annotations of type Experimental Modifier and Type Method Description AsyncInterceptorChain
AdvancedCache. getAsyncInterceptorChain()
Allows the modification of the interceptor chain.<R> Map<K,R>
LockedStream. 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.default <R> Map<K,R>
LockedStream. invokeAll(SerializableBiFunction<Cache<K,V>,? super CacheEntry<K,V>,R> biFunction)
Same asLockedStream.invokeAll(BiFunction)
except that the BiFunction must also implementSerializable
-
Uses of Experimental in org.infinispan.functional
Classes in org.infinispan.functional with annotations of type Experimental Modifier and Type Class Description class
EntryView
Entry views expose cached entry information to the user.static interface
EntryView.ReadEntryView<K,V>
Expose read-only information about a cache entry potentially associated with a key in the functional map.static interface
EntryView.ReadWriteEntryView<K,V>
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
EntryView.WriteEntryView<K,V>
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
FunctionalMap.ReadOnlyMap<K,V>
Exposes read-only operations that can be executed against the functional map.static interface
FunctionalMap.ReadWriteMap<K,V>
Exposes read-write operations that can be executed against the functional map.static interface
FunctionalMap.WriteOnlyMap<K,V>
Exposes write-only operations that can be executed against the functional map.class
Listeners
Holder class for functional listener definitions.static interface
Listeners.ReadWriteListeners<K,V>
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
Listeners.WriteListeners<K,V>
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
Listeners.WriteListeners.WriteListener<K,V>
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
MetaParam.Lookup
Provides metadata parameter lookup capabilities usingClass
as lookup key.static class
MetaParam.MetaCreated
Read only metadata parameter representing a cached entry's created time in milliseconds.static class
MetaParam.MetaEntryVersion
Writable metadata parameter representing a cached entry's generic version.static class
MetaParam.MetaLastUsed
Read only metadata parameter representing a cached entry's last used time in milliseconds.static class
MetaParam.MetaLifespan
Writable metadata parameter representing a cached entry's millisecond lifespan.static class
MetaParam.MetaLoadedFromPersistence
Non-writable parameter telling if the entry was loaded from a persistence tier (CacheLoader
) or not.static class
MetaParam.MetaLong
Abstract class for numeric long-based metadata parameter instances.static class
MetaParam.MetaMaxIdle
Writable metadata parameter representing a cached entry's millisecond max idle time.static interface
MetaParam.Writable<T>
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 class
Param.ExecutionMode
Defines where is the command executed.static class
Param.LockingMode
Normally the cache has to acquire locks during any write operation to guarantee its correctness.static class
Param.PersistenceMode
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 class
Param.ReplicationMode
static class
Param.StatisticsMode
Defines how statistics are gathered for this command.class
ParamIds
Parameter identifiers.interface
Traversable<T>
Unsorted traversable stream for sequential and aggregating operations. -
Uses of Experimental in org.infinispan.interceptors
Classes in org.infinispan.interceptors with annotations of type Experimental Modifier and Type Interface Description interface
AsyncInterceptor
Interface for sequential interceptors.interface
AsyncInterceptorChain
Interceptor chain usingAsyncInterceptor
s.class
BaseAsyncInterceptor
Base class for an interceptor in the new asynchronous invocation chain. -
Uses of Experimental in org.infinispan.lock
Classes in org.infinispan.lock with annotations of type Experimental Modifier and Type Class Description class
EmbeddedClusteredLockManagerFactory
AClusteredLockManager
factory for embedded cached. -
Uses of Experimental in org.infinispan.lock.api
Classes in org.infinispan.lock.api with annotations of type Experimental Modifier and Type Class Description class
ClusteredLockConfiguration
A Clustered Lock can be reentrant and there are different ownership levels.interface
ClusteredLockManager
Provides the API to define, create and remove ClusteredLocks. -
Uses of Experimental in org.infinispan.multimap.api
Classes in org.infinispan.multimap.api with annotations of type Experimental Modifier and Type Interface Description interface
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
Classes in org.infinispan.multimap.api.embedded with annotations of type Experimental Modifier and Type Interface Description interface
MultimapCache<K,V>
Embedded version of MultimapCache.interface
MultimapCacheManager<K,V>
-
Uses of Experimental in org.infinispan.notifications.cachelistener.filter
Methods in org.infinispan.notifications.cachelistener.filter with annotations of type Experimental Modifier and Type Method Description default boolean
CacheEventConverter. useRequestFormat()
-
Uses of Experimental in org.infinispan.persistence.spi
Classes in org.infinispan.persistence.spi with annotations of type Experimental Modifier and Type Interface Description interface
AdvancedCacheExpirationWriter<K,V>
Defines functionality for advanced expiration techniques. -
Uses of Experimental in org.infinispan.remoting.rpc
Methods in org.infinispan.remoting.rpc with annotations of type Experimental Modifier and Type Method Description <T> T
RpcManager. blocking(CompletionStage<T> request)
Block on a request and return its result.<T> CompletionStage<T>
RpcManager. invokeCommand(Collection<Address> targets, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)
Invoke a command on a collection of node and pass the responses to aResponseCollector
.<T> CompletionStage<T>
RpcManager. invokeCommand(Address target, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)
Invoke a command on a single node and pass the response to aResponseCollector
.<T> CompletionStage<T>
RpcManager. invokeCommandOnAll(org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)
Invoke a command on all the nodes in the cluster and pass the responses to aResponseCollector
.<T> CompletionStage<T>
RpcManager. invokeCommands(Collection<Address> targets, Function<Address,org.infinispan.commands.ReplicableCommand> commandGenerator, ResponseCollector<T> collector, RpcOptions rpcOptions)
Invoke different commands on a collection of nodes and pass the responses to aResponseCollector
.<T> CompletionStage<T>
RpcManager. invokeCommandStaggered(Collection<Address> targets, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)
Invoke a command on a collection of nodes and pass the responses to aResponseCollector
.void
RpcManager. sendToAll(org.infinispan.commands.ReplicableCommand command, DeliverOrder deliverOrder)
Asynchronously sends theReplicableCommand
to the entire cluster. -
Uses of Experimental in org.infinispan.remoting.transport
Classes in org.infinispan.remoting.transport with annotations of type Experimental Modifier and Type Interface Description interface
ResponseCollector<T>
A representation of a request's responses.class
ResponseCollectors
class
ValidResponseCollector<T>
Base class for response collectors, splitting responses into valid responses, exception responses, and target missing.class
ValidSingleResponseCollector<T>
Methods in org.infinispan.remoting.transport with annotations of type Experimental Modifier and Type Method Description default <T> CompletionStage<T>
Transport. invokeCommand(Collection<Address> targets, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, 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, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, 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, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, 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(org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, 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,org.infinispan.commands.ReplicableCommand> commandGenerator, ResponseCollector<T> collector, 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, org.infinispan.commands.ReplicableCommand command, ResponseCollector<T> collector, DeliverOrder deliverOrder, long timeout, TimeUnit unit)
Invoke a command on a collection of nodes and pass the responses to aResponseCollector
.default void
Transport. sendToAll(org.infinispan.commands.ReplicableCommand rpcCommand, DeliverOrder deliverOrder)
Asynchronously sends theReplicableCommand
to the entire cluster.
-