| Package | Description |
|---|---|
| org.infinispan |
This is the core of Infinispan, a distributed, transactional, highly scalable data grid
platform.
|
| org.infinispan.affinity |
This package contains the
KeyAffinityService interfaces which allow user code to determine mapping of keys onto nodes |
| org.infinispan.affinity.impl | |
| org.infinispan.cache.impl | |
| org.infinispan.commands.read | |
| org.infinispan.configuration.cache |
Cache configuration |
| org.infinispan.factories |
Factories are internal components used to create other components based on a cache's
configuration.
|
| org.infinispan.globalstate.impl | |
| org.infinispan.interceptors |
Infinispan is designed around a set of interceptors around a data container.
|
| org.infinispan.interceptors.distribution |
Interceptors dealing with command replication in distributed/replicated mode.
|
| org.infinispan.io |
Provides Infinispan-specific input and output streams, buffers and related utilities.
|
| org.infinispan.manager |
Cache manager API.
|
| org.infinispan.manager.impl | |
| org.infinispan.notifications.cachelistener.cluster | |
| org.infinispan.notifications.cachelistener.event |
Cache-specific listener events |
| org.infinispan.notifications.cachelistener.event.impl | |
| org.infinispan.persistence |
Persistence API.
|
| org.infinispan.persistence.spi |
The Persistence SPI.
|
| org.infinispan.reactive.publisher.impl | |
| org.infinispan.remoting |
Remote communication between cache instances.
|
| org.infinispan.security |
Security API.
|
| org.infinispan.security.actions | |
| org.infinispan.security.impl | |
| org.infinispan.statetransfer |
Transfer of state to new caches in a cluster.
|
| org.infinispan.stats.impl | |
| org.infinispan.stream |
Cache stream processing.
|
| org.infinispan.stream.impl | |
| org.infinispan.stream.impl.interceptor | |
| org.infinispan.stream.impl.local | |
| org.infinispan.upgrade | |
| 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.
|
| org.infinispan.util.logging.events | |
| org.infinispan.xsite |
| Modifier and Type | Interface and Description |
|---|---|
interface |
AdvancedCache<K,V>
An advanced interface that exposes additional methods not available on
Cache. |
| Modifier and Type | Method and Description |
|---|---|
void |
LockedStream.forEach(BiConsumer<Cache<K,V>,? super CacheEntry<K,V>> biConsumer)
Performs an action for each element of this stream on the primary owner of the given key.
|
<K,V> void |
CacheStream.forEach(BiConsumer<Cache<K,V>,? super R> action)
Same as
CacheStream.forEach(Consumer) except that it takes a BiConsumer that provides access
to the underlying Cache that is backing this stream. |
<K,V> void |
DoubleCacheStream.forEach(ObjDoubleConsumer<Cache<K,V>> action)
Same as
DoubleStream.forEach(DoubleConsumer) except that it takes an ObjDoubleConsumer that
provides access to the underlying Cache that is backing this stream. |
<K,V> void |
IntCacheStream.forEach(ObjIntConsumer<Cache<K,V>> action)
Same as
IntStream.forEach(IntConsumer) except that it takes an ObjIntConsumer that
provides access to the underlying Cache that is backing this stream. |
<K,V> void |
LongCacheStream.forEach(ObjLongConsumer<Cache<K,V>> action)
Same as
LongStream.forEach(LongConsumer) except that it takes an ObjLongConsumer that
provides access to the underlying Cache that is backing this stream. |
default void |
LockedStream.forEach(SerializableBiConsumer<Cache<K,V>,? super CacheEntry<K,V>> biConsumer)
Same as
LockedStream.forEach(BiConsumer) except that the BiConsumer must also
implement Serializable |
default <K,V> void |
CacheStream.forEach(SerializableBiConsumer<Cache<K,V>,? super R> action)
|
default <K,V> void |
DoubleCacheStream.forEach(SerializableObjDoubleConsumer<Cache<K,V>> action)
Same as
DoubleCacheStream.forEach(ObjDoubleConsumer) except that the BiConsumer must also implement
Serializable |
default <K,V> void |
IntCacheStream.forEach(SerializableObjIntConsumer<Cache<K,V>> action)
Same as
IntCacheStream.forEach(ObjIntConsumer) except that the BiConsumer must also implement
Serializable |
default <K,V> void |
LongCacheStream.forEach(SerializableObjLongConsumer<Cache<K,V>> action)
Same as
LongCacheStream.forEach(ObjLongConsumer) except that the BiConsumer must also implement
Serializable |
<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 |
| Modifier and Type | Method and Description |
|---|---|
static <K,V> KeyAffinityService<K> |
KeyAffinityServiceFactory.newKeyAffinityService(Cache<K,V> cache,
Collection<Address> filter,
KeyGenerator<K> keyGenerator,
Executor ex,
int keyBufferSize)
|
static <K,V> KeyAffinityService<K> |
KeyAffinityServiceFactory.newKeyAffinityService(Cache<K,V> cache,
Collection<Address> filter,
KeyGenerator<K> keyGenerator,
Executor ex,
int keyBufferSize,
boolean start)
Creates a service that would only generate keys for addresses specified in filter.
|
static <K,V> KeyAffinityService<K> |
KeyAffinityServiceFactory.newKeyAffinityService(Cache<K,V> cache,
Executor ex,
KeyGenerator<K> keyGenerator,
int keyBufferSize)
|
static <K,V> KeyAffinityService<K> |
KeyAffinityServiceFactory.newKeyAffinityService(Cache<K,V> cache,
Executor ex,
KeyGenerator<K> keyGenerator,
int keyBufferSize,
boolean start)
Creates an
KeyAffinityService instance that generates keys mapped to all addresses
in the cluster. |
static <K,V> KeyAffinityService<K> |
KeyAffinityServiceFactory.newLocalKeyAffinityService(Cache<K,V> cache,
KeyGenerator<K> keyGenerator,
Executor ex,
int keyBufferSize)
|
static <K,V> KeyAffinityService<K> |
KeyAffinityServiceFactory.newLocalKeyAffinityService(Cache<K,V> cache,
KeyGenerator<K> keyGenerator,
Executor ex,
int keyBufferSize,
boolean start)
Created an service that only generates keys for the local address.
|
| Constructor and Description |
|---|
KeyAffinityServiceImpl(Executor executor,
Cache<? extends K,?> cache,
KeyGenerator<? extends K> keyGenerator,
int bufferSize,
Collection<Address> filter,
boolean start) |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractDelegatingAdvancedCache<K,V>
Similar to
AbstractDelegatingCache, but for AdvancedCache. |
class |
AbstractDelegatingCache<K,V>
This is a convenient base class for implementing a cache delegate.
|
class |
CacheImpl<K,V> |
class |
DecoratedCache<K,V>
A decorator to a cache, which can be built with a specific set of
Flags. |
class |
EncoderCache<K,V>
|
class |
SimpleCacheImpl<K,V>
Simple local cache without interceptor stack.
|
class |
StatsCollectingCache<K,V>
Wraps existing
AdvancedCache to collect statistics |
| Modifier and Type | Method and Description |
|---|---|
static <K,V> Cache<K,V> |
Caches.getCacheWithFlags(Cache<K,V> cache,
FlagAffectedCommand command) |
Cache<K,V> |
AbstractDelegatingCache.getDelegate() |
static <K,V> Cache<K,V> |
AbstractDelegatingCache.unwrapCache(Cache<K,V> cache)
Fully unwraps a given cache returning the base cache.
|
| Modifier and Type | Method and Description |
|---|---|
static <K,V> Cache<K,V> |
Caches.getCacheWithFlags(Cache<K,V> cache,
FlagAffectedCommand command) |
static <K,V> Cache<K,V> |
AbstractDelegatingCache.unwrapCache(Cache<K,V> cache)
Fully unwraps a given cache returning the base cache.
|
| Constructor and Description |
|---|
AbstractDelegatingCache(Cache<K,V> cache) |
| Modifier and Type | Field and Description |
|---|---|
protected Cache<K,V> |
AbstractCloseableIteratorCollection.cache |
| Constructor and Description |
|---|
AbstractCloseableIteratorCollection(Cache<K,V> cache) |
| Modifier and Type | Method and Description |
|---|---|
void |
CustomFailurePolicy.init(Cache<K,V> cache)
Invoked during the initialization phase.
|
| Modifier and Type | Method and Description |
|---|---|
Cache<K,V> |
InternalCacheFactory.createCache(Configuration configuration,
GlobalComponentRegistry globalComponentRegistry,
String cacheName)
This implementation clones the configuration passed in before using it.
|
| Modifier and Type | Method and Description |
|---|---|
Cache<ScopedState,Object> |
GlobalConfigurationManagerImpl.getStateCache() |
| Modifier and Type | Field and Description |
|---|---|
protected Cache<?,?> |
BaseCustomAsyncInterceptor.cache |
| Constructor and Description |
|---|
BackingKeySet(Cache<K,V> cache,
CacheSet<K> keySet,
FlagAffectedCommand command) |
| Modifier and Type | Field and Description |
|---|---|
protected Cache<String,byte[]> |
GridFilesystem.data
Deprecated.
|
protected Cache<String,GridFile.Metadata> |
GridFilesystem.metadata
Deprecated.
|
| Constructor and Description |
|---|
GridFilesystem(Cache<String,byte[]> data,
Cache<String,GridFile.Metadata> metadata)
Deprecated.
|
GridFilesystem(Cache<String,byte[]> data,
Cache<String,GridFile.Metadata> metadata)
Deprecated.
|
GridFilesystem(Cache<String,byte[]> data,
Cache<String,GridFile.Metadata> metadata,
int defaultChunkSize)
Deprecated.
Creates an instance.
|
GridFilesystem(Cache<String,byte[]> data,
Cache<String,GridFile.Metadata> metadata,
int defaultChunkSize)
Deprecated.
Creates an instance.
|
| Modifier and Type | Method and Description |
|---|---|
<K,V> Cache<K,V> |
DefaultCacheManager.createCache(String name,
Configuration configuration) |
<K,V> Cache<K,V> |
DefaultCacheManagerAdmin.createCache(String cacheName,
Configuration configuration) |
<K,V> Cache<K,V> |
EmbeddedCacheManager.createCache(String name,
Configuration configuration)
Creates a cache on the local node using the supplied configuration.
|
<K,V> Cache<K,V> |
EmbeddedCacheManagerAdmin.createCache(String name,
Configuration configuration)
Creates a cache across the cluster.
|
<K,V> Cache<K,V> |
DefaultCacheManagerAdmin.createCache(String cacheName,
String template) |
<K,V> Cache<K,V> |
EmbeddedCacheManagerAdmin.createCache(String name,
String template)
Creates a cache on the container using the specified template.
|
<K,V> Cache<K,V> |
CacheContainer.getCache() |
<K,V> Cache<K,V> |
DefaultCacheManager.getCache()
Retrieves the default cache associated with this cache manager.
|
<K,V> Cache<K,V> |
EmbeddedCacheManager.getCache()
Retrieves the default cache associated with this cache container.
|
<K,V> Cache<K,V> |
CacheContainer.getCache(String cacheName) |
<K,V> Cache<K,V> |
DefaultCacheManager.getCache(String cacheName)
Retrieves a named cache from the system.
|
<K,V> Cache<K,V> |
EmbeddedCacheManager.getCache(String cacheName)
Retrieves a cache by name.
|
<K,V> Cache<K,V> |
DefaultCacheManager.getCache(String cacheName,
boolean createIfAbsent) |
<K,V> Cache<K,V> |
EmbeddedCacheManager.getCache(String cacheName,
boolean createIfAbsent)
Similar to
EmbeddedCacheManager.getCache(String), except if has the option
to not create the cache if it is not already running. |
<K,V> Cache<K,V> |
DefaultCacheManagerAdmin.getOrCreateCache(String cacheName,
Configuration configuration) |
<K,V> Cache<K,V> |
EmbeddedCacheManagerAdmin.getOrCreateCache(String name,
Configuration configuration)
Retrieves an existing cache or creates one across the cluster using the specified configuration.
|
<K,V> Cache<K,V> |
DefaultCacheManagerAdmin.getOrCreateCache(String cacheName,
String template) |
<K,V> Cache<K,V> |
EmbeddedCacheManagerAdmin.getOrCreateCache(String name,
String template)
Retrieves an existing cache or creates one using the specified template if it doesn't exist
|
| Modifier and Type | Method and Description |
|---|---|
<K,V> Cache<K,V> |
AbstractDelegatingEmbeddedCacheManager.createCache(String name,
Configuration configuration) |
<K,V> Cache<K,V> |
AbstractDelegatingEmbeddedCacheManager.getCache() |
<K,V> Cache<K,V> |
AbstractDelegatingEmbeddedCacheManager.getCache(String cacheName) |
<K,V> Cache<K,V> |
AbstractDelegatingEmbeddedCacheManager.getCache(String cacheName,
boolean createIfAbsent) |
| Modifier and Type | Method and Description |
|---|---|
Cache<K,V> |
ClusterEvent.getCache() |
| Modifier and Type | Method and Description |
|---|---|
void |
ClusterListenerReplicateCallable.accept(EmbeddedCacheManager cacheManager,
Cache<K,V> cache) |
| Modifier and Type | Method and Description |
|---|---|
Cache<K,V> |
Event.getCache() |
| Modifier and Type | Method and Description |
|---|---|
Cache<K,V> |
EventImpl.getCache() |
| Modifier and Type | Method and Description |
|---|---|
static <K,V> EventImpl<K,V> |
EventImpl.createEvent(Cache<K,V> cache,
Event.Type type) |
| Modifier and Type | Method and Description |
|---|---|
Cache |
InitializationContextImpl.getCache() |
| Constructor and Description |
|---|
InitializationContextImpl(StoreConfiguration configuration,
Cache cache,
KeyPartitioner keyPartitioner,
PersistenceMarshaller marshaller,
TimeService timeService,
ByteBufferFactory byteBufferFactory,
MarshallableEntryFactory marshallableEntryFactory,
Executor nonBlockingExecutor,
GlobalConfiguration globalConfiguration,
BlockingManager blockingManager) |
| Modifier and Type | Method and Description |
|---|---|
Cache |
InitializationContext.getCache() |
| Modifier and Type | Field and Description |
|---|---|
protected ComponentRef<Cache<?,?>> |
PartitionAwareClusterPublisherManager.cache |
| Modifier and Type | Method and Description |
|---|---|
static LocalInvocation |
LocalInvocation.newInstanceFromCache(Cache<?,?> cache,
CacheRpcCommand command) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
SecureCache<K,V>
SecureCache.
|
| Modifier and Type | Method and Description |
|---|---|
Cache<?,?> |
GlobalSecurityManager.globalACLCache()
Returns the global ACL cache
|
| Modifier and Type | Method and Description |
|---|---|
Cache<?,?> |
GetCacheAction.run() |
| Constructor and Description |
|---|
GetClusterExecutorAction(Cache<?,?> cache) |
| Modifier and Type | Class and Description |
|---|---|
class |
SecureCacheImpl<K,V>
SecureCacheImpl.
|
| Modifier and Type | Method and Description |
|---|---|
Cache<?,?> |
GlobalSecurityManagerImpl.globalACLCache() |
| Modifier and Type | Field and Description |
|---|---|
protected ComponentRef<Cache<Object,Object>> |
StateConsumerImpl.cache |
| Modifier and Type | Method and Description |
|---|---|
void |
ClusterCacheStatsImpl.injectDependencies(Cache<?,?> cache,
Configuration configuration) |
| Modifier and Type | Method and Description |
|---|---|
void |
CacheAware.injectCache(Cache<K,V> cache)
Method that is invoked when a cache is to be injected.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TxLockedStreamImpl.forEach(BiConsumer<Cache<K,V>,? super CacheEntry<K,V>> biConsumer) |
void |
LockedStreamImpl.forEach(BiConsumer<Cache<K,V>,? super CacheEntry<K,V>> biConsumer) |
<K,V> void |
DistributedCacheStream.forEach(BiConsumer<Cache<K,V>,? super R> action) |
<K,V> void |
IntermediateCacheStream.forEach(BiConsumer<Cache<K,V>,? super R> action) |
<K,V> void |
DistributedDoubleCacheStream.forEach(ObjDoubleConsumer<Cache<K,V>> action) |
<K,V> void |
IntermediateDoubleCacheStream.forEach(ObjDoubleConsumer<Cache<K,V>> action) |
<K,V> void |
DistributedIntCacheStream.forEach(ObjIntConsumer<Cache<K,V>> action) |
<K,V> void |
IntermediateIntCacheStream.forEach(ObjIntConsumer<Cache<K,V>> action) |
<K,V> void |
DistributedLongCacheStream.forEach(ObjLongConsumer<Cache<K,V>> action) |
<K,V> void |
IntermediateLongCacheStream.forEach(ObjLongConsumer<Cache<K,V>> action) |
<K,V> void |
DistributedDoubleCacheStream.forEach(SerializableObjDoubleConsumer<Cache<K,V>> action) |
<K,V> void |
DistributedIntCacheStream.forEach(SerializableObjIntConsumer<Cache<K,V>> action) |
<K,V> void |
DistributedLongCacheStream.forEach(SerializableObjLongConsumer<Cache<K,V>> action) |
<R> Map<K,R> |
TxLockedStreamImpl.invokeAll(BiFunction<Cache<K,V>,? super CacheEntry<K,V>,R> biFunction) |
<R> Map<K,R> |
LockedStreamImpl.invokeAll(BiFunction<Cache<K,V>,? super CacheEntry<K,V>,R> biFunction) |
| Constructor and Description |
|---|
RemovableCloseableIterator(CloseableIterator<C> realIterator,
Cache<K,?> cache,
Function<? super C,K> removeFunction)
Deprecated.
|
RemovableIterator(Iterator<C> realIterator,
Cache<K,?> cache,
Function<? super C,K> removeFunction)
Deprecated.
|
| Constructor and Description |
|---|
AbstractDelegatingEntryCacheSet(Cache<K,V> cache,
CacheSet<CacheEntry<K,V>> set) |
AbstractDelegatingKeyCacheSet(Cache<K,V> cache,
CacheSet<K> set) |
| Modifier and Type | Method and Description |
|---|---|
<K,V> void |
LocalCacheStream.forEach(BiConsumer<Cache<K,V>,? super R> action) |
<K,V> void |
LocalDoubleCacheStream.forEach(ObjDoubleConsumer<Cache<K,V>> action) |
<K,V> void |
LocalIntCacheStream.forEach(ObjIntConsumer<Cache<K,V>> action) |
<K,V> void |
LocalLongCacheStream.forEach(ObjLongConsumer<Cache<K,V>> action) |
| Modifier and Type | Method and Description |
|---|---|
void |
TargetMigrator.disconnectSource(Cache<Object,Object> cache)
Disconnects the target from the source.
|
long |
TargetMigrator.synchronizeData(Cache<Object,Object> cache)
Performs the synchronization of data between source and target
|
long |
TargetMigrator.synchronizeData(Cache<Object,Object> cache,
int readBatch,
int threads)
Performs the synchronization of data between source and target
|
| Modifier and Type | Method and Description |
|---|---|
<K,V> void |
AbstractDelegatingCacheStream.forEach(BiConsumer<Cache<K,V>,? super R> action) |
| Constructor and Description |
|---|
DataContainerRemoveIterator(Cache<K,V> cache) |
DataContainerRemoveIterator(Cache<K,V> cache,
DataContainer<K,V> dataContainer) |
EntryWrapper(Cache<K,V> cache,
CacheEntry<K,V> entry)
Creates a new entry wrapper given the cache and entry.
|
| Modifier and Type | Method and Description |
|---|---|
default EventLogger |
EventLogger.context(Cache<?,?> cache)
Sets a cache as context of this event log.
|
| Modifier and Type | Field and Description |
|---|---|
protected Cache<K,V> |
AbstractCustomFailurePolicy.cache |
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractCustomFailurePolicy.init(Cache<K,V> cache) |
Copyright © 2022 JBoss by Red Hat. All rights reserved.