| Package | Description |
|---|---|
| org.infinispan |
This is the core of Infinispan, a distributed, transactional, highly scalable data grid
platform.
|
| org.infinispan.client.hotrod.multimap | |
| org.infinispan.factories.impl | |
| org.infinispan.functional |
Functional API package
|
| org.infinispan.functional.impl | |
| org.infinispan.interceptors |
Infinispan is designed around a set of interceptors around a data container.
|
| org.infinispan.multimap.api |
MultimapCache API.
|
| org.infinispan.notifications.cachelistener.filter |
Cache-specific notifications and eventing filtering classes. |
| org.infinispan.persistence.spi |
The Persistence SPI.
|
| org.infinispan.remoting.transport |
Transports handle the low-level networking, used by the remoting components.
|
| org.infinispan.remoting.transport.impl | |
| org.infinispan.util |
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.
|
| Package | Description |
|---|---|
| org.infinispan.functional |
Functional API package
|
| Modifier and Type | Method and Description |
|---|---|
<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 as
LockedStream.invokeAll(BiFunction) except that the BiFunction must also
implement Serializable |
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.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
MultimapCacheManager<K,V> |
| Modifier and Type | Method and Description |
|---|---|
MBeanMetadata |
BasicComponentRegistry.getMBeanMetadata(String className) |
Collection<ComponentRef<?>> |
BasicComponentRegistry.getRegisteredComponents()
Run
consumer for each registered component in the current scope. |
boolean |
BasicComponentRegistry.hasComponentAccessor(String componentClassName)
Check if a component accessor has been registered for class
componentClassName |
<T> ComponentRef<T> |
BasicComponentRegistry.lazyGetComponent(Class<T> componentType)
Looks up a component named
name 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 with
BasicComponentRegistry.replaceComponent(String, Object, boolean). |
| Modifier and Type | Class and 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 using
Class 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>
Writable
MetaParam 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.
|
| Modifier and Type | Class and Description |
|---|---|
class |
EntryViews
Entry views implementation class holder.
|
class |
FunctionalMapImpl<K,V>
Functional map implementation.
|
interface |
FunctionalNotifier<K,V>
Listener notifier.
|
class |
FunctionalNotifierImpl<K,V> |
class |
MetaParams
Represents a
MetaParam collection. |
class |
MetaParamsInternalMetadata
Metadata parameters backed internal metadata representation.
|
class |
Params
Internal class that encapsulates collection of parameters used to tweak
functional map operations.
|
class |
ReadOnlyMapImpl<K,V>
Read-only map implementation.
|
class |
ReadWriteMapImpl<K,V>
Read-write map implementation.
|
class |
WriteOnlyMapImpl<K,V>
Write-only map implementation.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
AsyncInterceptor
Interface for sequential interceptors.
|
interface |
AsyncInterceptorChain
Interceptor chain using
AsyncInterceptors. |
class |
BaseAsyncInterceptor
Base class for an interceptor in the new asynchronous invocation chain.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
BasicMultimapCache<K,V>
BasicMultimapCache provides the common API for the two different types of multimap caches that Infinispan
provides: embedded and remote. |
| Modifier and Type | Method and Description |
|---|---|
default boolean |
CacheEventConverter.useRequestFormat() |
| Modifier and Type | Interface and Description |
|---|---|
interface |
AdvancedCacheExpirationWriter<K,V>
Deprecated.
since 11.0 replaced by
NonBlockingStore |
interface |
NonBlockingStore<K,V>
The contract for defining how caches interface with external sources of data, such as databases or filesystems.
|
| Modifier and Type | Method and Description |
|---|---|
default boolean |
NonBlockingStore.ignoreCommandWithFlags(long commandFlags)
Some stores may not want to perform operations based on if a command has certain flags.
|
| Modifier and Type | Interface and 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> |
| Modifier and Type | Method and Description |
|---|---|
default <T> CompletionStage<T> |
Transport.invokeCommand(Address target,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit)
Invoke a command on a single node and pass the response to a
ResponseCollector. |
default <T> CompletionStage<T> |
Transport.invokeCommand(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit)
Invoke a command on a collection of node and pass the responses to a
ResponseCollector. |
default <T> CompletionStage<T> |
Transport.invokeCommandOnAll(Collection<Address> requiredTargets,
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 a
ResponseCollector. |
default <T> CompletionStage<T> |
Transport.invokeCommandOnAll(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 a
ResponseCollector. |
default <T> CompletionStage<T> |
Transport.invokeCommands(Collection<Address> targets,
Function<Address,ReplicableCommand> commandGenerator,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit timeUnit)
Invoke different commands on a collection of nodes and pass the responses to a
ResponseCollector. |
default <T> CompletionStage<T> |
Transport.invokeCommandStaggered(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit)
Invoke a command on a collection of nodes and pass the responses to a
ResponseCollector. |
default void |
Transport.sendToAll(ReplicableCommand rpcCommand,
DeliverOrder deliverOrder)
Asynchronously sends the
ReplicableCommand to the entire cluster. |
| Modifier and Type | Class and Description |
|---|---|
class |
MapResponseCollector
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
ExponentialBackOff
Interface to implement an exponential back-off algorithm that retries the request based on the result of the remote
operation.
|
Copyright © 2022 JBoss by Red Hat. All rights reserved.