Uses of Interface
org.infinispan.Cache
Package
Description
This is the core of Infinispan, a distributed, transactional, highly scalable data grid
platform.
This package contains the
KeyAffinityService
interfaces which allow user code to determine mapping of keys onto nodesCache
configurationFactories are internal components used to create other components based on a cache's
configuration.
Functional API package
Global configuration state.
Infinispan is designed around a set of interceptors around a data container.
Cache manager API.
invalid reference
Cache
Persistence API.
The Persistence SPI.
Query API that lets you perform Ickle queries and look up values in caches.
Query module internals.
Remote communication between cache instances.
Security API.
Cache stream processing.
Server tasks API.
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 Cache in org.infinispan
Modifier and TypeInterfaceDescriptioninterface
AdvancedCache<K,
V> An advanced interface that exposes additional methods not available onCache
.Modifier and TypeMethodDescription<K,
V> void CacheStream.forEach
(BiConsumer<Cache<K, V>, ? super R> action) Same asCacheStream.forEach(Consumer)
except that it takes aBiConsumer
that provides access to the underlyingCache
that is backing this stream.default <K,
V> void CacheStream.forEach
(SerializableBiConsumer<Cache<K, V>, ? super R> action) <K,
V> void DoubleCacheStream.forEach
(ObjDoubleConsumer<Cache<K, V>> action) Same asDoubleStream.forEach(DoubleConsumer)
except that it takes anObjDoubleConsumer
that provides access to the underlyingCache
that is backing this stream.default <K,
V> void DoubleCacheStream.forEach
(SerializableObjDoubleConsumer<Cache<K, V>> action) Same asDoubleCacheStream.forEach(ObjDoubleConsumer)
except that theBiConsumer
must also implementSerializable
<K,
V> void IntCacheStream.forEach
(ObjIntConsumer<Cache<K, V>> action) Same asIntStream.forEach(IntConsumer)
except that it takes anObjIntConsumer
that provides access to the underlyingCache
that is backing this stream.default <K,
V> void IntCacheStream.forEach
(SerializableObjIntConsumer<Cache<K, V>> action) Same asIntCacheStream.forEach(ObjIntConsumer)
except that theBiConsumer
must also implementSerializable
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.default void
LockedStream.forEach
(SerializableBiConsumer<Cache<K, V>, ? super CacheEntry<K, V>> biConsumer) Same asLockedStream.forEach(BiConsumer)
except that the BiConsumer must also implementSerializable
<K,
V> void LongCacheStream.forEach
(ObjLongConsumer<Cache<K, V>> action) Same asLongStream.forEach(LongConsumer)
except that it takes anObjLongConsumer
that provides access to the underlyingCache
that is backing this stream.default <K,
V> void LongCacheStream.forEach
(SerializableObjLongConsumer<Cache<K, V>> action) Same asLongCacheStream.forEach(ObjLongConsumer)
except that theBiConsumer
must also implementSerializable
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.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 Cache in org.infinispan.affinity
Modifier and TypeMethodDescriptionstatic <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 anKeyAffinityService
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. -
Uses of Cache in org.infinispan.affinity.impl
ModifierConstructorDescriptionKeyAffinityServiceImpl
(Executor executor, Cache<? extends K, ?> cache, KeyGenerator<? extends K> keyGenerator, int bufferSize, Collection<Address> filter, boolean start) -
Uses of Cache in org.infinispan.cache.impl
Modifier and TypeClassDescriptionclass
Similar toAbstractDelegatingCache
, but forAdvancedCache
.class
This is a convenient base class for implementing a cache delegate.class
AliasCache<K,
V> class
CacheImpl<K,
V> class
DecoratedCache<K,
V> A decorator to a cache, which can be built with a specific set ofFlag
s.class
EncoderCache<K,
V> class
SimpleCacheImpl<K,
V> Simple local cache without interceptor stack.class
StatsCollectingCache<K,
V> Wraps existingAdvancedCache
to collect statisticsModifier and TypeMethodDescriptionAbstractDelegatingCache.getDelegate()
static <K,
V> Cache <K, V> AbstractDelegatingCache.unwrapCache
(Cache<K, V> cache) Fully unwraps a given cache returning the base cache.Modifier and TypeMethodDescription<K,
V> ContinuousQuery <K, V> QueryProducer.continuousQuery
(Cache<K, V> cache) static <K,
V> Cache <K, V> AbstractDelegatingCache.unwrapCache
(Cache<K, V> cache) Fully unwraps a given cache returning the base cache. -
Uses of Cache in org.infinispan.configuration.cache
-
Uses of Cache in org.infinispan.factories
Modifier and TypeMethodDescriptionInternalCacheFactory.createCache
(Configuration configuration, GlobalComponentRegistry globalComponentRegistry, String cacheName) This implementation clones the configuration passed in before using it.Modifier and TypeMethodDescriptionstatic <T> T
ComponentRegistry.componentOf
(Cache<?, ?> cache, Class<T> type) static <T> T
ComponentRegistry.componentOf
(Cache<?, ?> cache, Class<T> type, String name) static <K,
V> ComponentRegistry -
Uses of Cache in org.infinispan.functional
-
Uses of Cache in org.infinispan.functional.impl
-
Uses of Cache in org.infinispan.globalstate
Modifier and TypeMethodDescription<V> Cache
<ScopedState, V> GlobalConfigurationManager.getStateCache()
Returns the global state cache -
Uses of Cache in org.infinispan.globalstate.impl
-
Uses of Cache in org.infinispan.interceptors
-
Uses of Cache in org.infinispan.manager
Modifier and TypeMethodDescription<K,
V> Cache <K, V> DefaultCacheManager.createCache
(String name, Configuration configuration) <K,
V> Cache <K, V> DefaultCacheManagerAdmin.createCache
(String cacheName, String template) <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, String template) Creates a cache on the container using the specified template.<K,
V> Cache <K, V> EmbeddedCacheManagerAdmin.createCache
(String name, Configuration configuration) Creates a cache across the cluster.<K,
V> Cache <K, V> CacheContainer.getCache()
<K,
V> Cache <K, V> <K,
V> Cache <K, V> DefaultCacheManager.getCache()
Retrieves the default cache associated with this cache manager.<K,
V> Cache <K, V> Retrieves a named cache from the system.<K,
V> Cache <K, V> <K,
V> Cache <K, V> EmbeddedCacheManager.getCache()
Retrieves the default cache associated with this cache container.<K,
V> Cache <K, V> Retrieves a cache by name.<K,
V> Cache <K, V> Similar toEmbeddedCacheManager.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, String template) <K,
V> Cache <K, V> DefaultCacheManagerAdmin.getOrCreateCache
(String cacheName, Configuration configuration) <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<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. -
Uses of Cache in org.infinispan.manager.impl
Modifier and TypeMethodDescription<K,
V> Cache <K, V> AbstractDelegatingEmbeddedCacheManager.createCache
(String name, Configuration configuration) <K,
V> Cache <K, V> AbstractDelegatingEmbeddedCacheManager.getCache()
<K,
V> Cache <K, V> <K,
V> Cache <K, V> -
Uses of Cache in org.infinispan.multimap.impl
ModifierConstructorDescriptionEmbeddedMultimapCache
(Cache<K, Bucket<V>> cache, boolean supportsDuplicates) EmbeddedMultimapListCache
(Cache<K, ListBucket<V>> cache) EmbeddedMultimapPairCache
(Cache<K, HashMapBucket<HK, HV>> cache) EmbeddedMultimapSortedSetCache
(Cache<K, SortedSetBucket<V>> cache) EmbeddedSetCache
(Cache<K, SetBucket<V>> cache) -
Uses of Cache in org.infinispan.notifications.cachelistener.cluster
Modifier and TypeMethodDescriptionvoid
ClusterListenerReplicateCallable.accept
(EmbeddedCacheManager cacheManager, Cache<K, V> cache) -
Uses of Cache in org.infinispan.notifications.cachelistener.event
-
Uses of Cache in org.infinispan.notifications.cachelistener.event.impl
Modifier and TypeMethodDescriptionstatic <K,
V> EventImpl <K, V> EventImpl.createEvent
(Cache<K, V> cache, Event.Type type) -
Uses of Cache in org.infinispan.persistence
ModifierConstructorDescriptionInitializationContextImpl
(StoreConfiguration configuration, Cache cache, KeyPartitioner keyPartitioner, PersistenceMarshaller marshaller, TimeService timeService, ByteBufferFactory byteBufferFactory, MarshallableEntryFactory marshallableEntryFactory, Executor nonBlockingExecutor, GlobalConfiguration globalConfiguration, BlockingManager blockingManager, NonBlockingManager nonBlockingManager) -
Uses of Cache in org.infinispan.persistence.remote.upgrade
Modifier and TypeMethodDescriptionvoid
HotRodTargetMigrator.connectSource
(Cache<Object, Object> cache, StoreConfiguration configuration) void
HotRodTargetMigrator.disconnectSource
(Cache<Object, Object> cache) boolean
HotRodTargetMigrator.isConnected
(Cache<Object, Object> cache) long
HotRodTargetMigrator.synchronizeData
(Cache<Object, Object> cache) long
HotRodTargetMigrator.synchronizeData
(Cache<Object, Object> cache, int readBatch, int threads) -
Uses of Cache in org.infinispan.persistence.spi
-
Uses of Cache in org.infinispan.persistence.support
-
Uses of Cache in org.infinispan.query
Modifier and TypeMethodDescriptionstatic CompletionStage
<org.infinispan.query.core.stats.SearchStatisticsSnapshot> Search.getClusteredSearchStatistics
(Cache<?, ?> cache) Returns aggregated search statistics for all nodes in the cluster.static <K,
V> ContinuousQuery <K, V> Search.getContinuousQuery
(Cache<K, V> cache) Deprecated.static <K,
V> Indexer Search.getIndexer
(Cache<K, V> cache) static QueryFactory
Search.getQueryFactory
(Cache<?, ?> cache) Obtains a query factory to build DSL-based Ickle queries.static <K,
V> org.infinispan.query.core.stats.SearchStatistics Search.getSearchStatistics
(Cache<K, V> cache) Returns search statistics for the local node. -
Uses of Cache in org.infinispan.query.impl
Modifier and TypeMethodDescriptionstatic org.infinispan.query.dsl.embedded.impl.QueryEngine
<Class<?>> ComponentRegistryUtils.getEmbeddedQueryEngine
(Cache<?, ?> cache) static KeyPartitioner
ComponentRegistryUtils.getKeyPartitioner
(Cache<?, ?> cache) static org.infinispan.query.backend.KeyTransformationHandler
ComponentRegistryUtils.getKeyTransformationHandler
(Cache<?, ?> cache) static org.infinispan.query.core.stats.impl.LocalQueryStatistics
ComponentRegistryUtils.getLocalQueryStatistics
(Cache<?, ?> cache) static org.infinispan.query.core.impl.QueryCache
ComponentRegistryUtils.getQueryCache
(Cache<?, ?> cache) Returns the optional QueryCache.static org.infinispan.query.backend.QueryInterceptor
ComponentRegistryUtils.getQueryInterceptor
(Cache<?, ?> cache) static SearchMapping
ComponentRegistryUtils.getSearchMapping
(Cache<?, ?> cache) static org.infinispan.query.core.stats.impl.SearchStatsRetriever
ComponentRegistryUtils.getSearchStatsRetriever
(Cache<?, ?> cache) static TimeService
ComponentRegistryUtils.getTimeService
(Cache<?, ?> cache) -
Uses of Cache in org.infinispan.reactive.publisher.impl
Modifier and TypeFieldDescriptionprotected ComponentRef
<Cache<?, ?>> PartitionAwareClusterPublisherManager.cache
-
Uses of Cache in org.infinispan.remoting
Modifier and TypeMethodDescriptionstatic LocalInvocation
LocalInvocation.newInstanceFromCache
(Cache<?, ?> cache, org.infinispan.commands.remote.CacheRpcCommand command) -
Uses of Cache in org.infinispan.rest.resources
Modifier and TypeFieldDescriptionprotected final Cache
<?, ?> CacheResourceV2.BaseCacheListener.cache
ModifierConstructorDescriptionprotected
BaseCacheListener
(Cache<?, ?> cache) StatefulCacheListener
(Cache<?, ?> cache) StatelessCacheListener
(Cache<?, ?> cache) -
Uses of Cache in org.infinispan.security
-
Uses of Cache in org.infinispan.security.actions
Modifier and TypeClassDescriptionclass
GetCacheAction<A extends Cache<K,
V>, K, V> GetCacheAction.class
GetOrCreateCacheAction<A extends Cache<K,
V>, K, V> GetOrCreateCacheAction.class
GetUnwrappedCacheAction<A extends Cache<K,
V>, K, V> GetUnwrappedCacheAction.class
GetUnwrappedNameCacheAction<A extends Cache<K,
V>, K, V> GetUnwrappedNameCacheAction.Modifier and TypeMethodDescriptionstatic <A extends Cache<K,
V>, K, V>
ASecurityActions.getCache
(EmbeddedCacheManager cacheManager, String cacheName) static <A extends Cache<K,
V>, K, V>
ASecurityActions.getOrCreateCache
(EmbeddedCacheManager cm, String configName, Configuration cfg) static <A extends Cache<K,
V>, K, V>
ASecurityActions.getUnwrappedCache
(Cache<K, V> cache) static <A extends Cache<K,
V>, K, V>
ASecurityActions.getUnwrappedCache
(EmbeddedCacheManager cacheManager, String cacheName) Modifier and TypeMethodDescriptionstatic ClusterExecutor
SecurityActions.getClusterExecutor
(Cache<?, ?> cache) static <A extends Cache<K,
V>, K, V>
ASecurityActions.getUnwrappedCache
(Cache<K, V> cache) static void
ModifierConstructorDescriptionGetClusterExecutorAction
(Cache<?, ?> cache) GetUnwrappedCacheAction
(Cache<K, V> cache) -
Uses of Cache in org.infinispan.security.impl
-
Uses of Cache in org.infinispan.server.hotrod
-
Uses of Cache in org.infinispan.server.hotrod.tx.table
ModifierConstructorDescriptionGlobalTxTable
(Cache<CacheXid, TxState> storage, GlobalComponentRegistry gcr) -
Uses of Cache in org.infinispan.server.iteration
Modifier and TypeMethodDescriptionvoid
IterationFilter.injectDependencies
(Cache cache, EncoderRegistry encoderRegistry) -
Uses of Cache in org.infinispan.server.memcached
-
Uses of Cache in org.infinispan.stream
Modifier and TypeMethodDescriptionvoid
CacheAware.injectCache
(Cache<K, V> cache) Method that is invoked when a cache is to be injected. -
Uses of Cache in org.infinispan.stream.impl
Modifier and TypeMethodDescription<K,
V> void DistributedCacheStream.forEach
(BiConsumer<Cache<K, V>, ? super R> action) <K,
V> void DistributedDoubleCacheStream.forEach
(ObjDoubleConsumer<Cache<K, V>> action) <K,
V> void DistributedDoubleCacheStream.forEach
(SerializableObjDoubleConsumer<Cache<K, V>> action) <K,
V> void DistributedIntCacheStream.forEach
(ObjIntConsumer<Cache<K, V>> action) <K,
V> void DistributedIntCacheStream.forEach
(SerializableObjIntConsumer<Cache<K, V>> action) <K,
V> void DistributedLongCacheStream.forEach
(ObjLongConsumer<Cache<K, V>> action) <K,
V> void DistributedLongCacheStream.forEach
(SerializableObjLongConsumer<Cache<K, V>> action) <K,
V> void IntermediateCacheStream.forEach
(BiConsumer<Cache<K, V>, ? super R> action) <K,
V> void IntermediateDoubleCacheStream.forEach
(ObjDoubleConsumer<Cache<K, V>> action) <K,
V> void IntermediateIntCacheStream.forEach
(ObjIntConsumer<Cache<K, V>> action) <K,
V> void IntermediateLongCacheStream.forEach
(ObjLongConsumer<Cache<K, V>> action) void
LockedStreamImpl.forEach
(BiConsumer<Cache<K, V>, ? super CacheEntry<K, V>> biConsumer) void
TxLockedStreamImpl.forEach
(BiConsumer<Cache<K, V>, ? super CacheEntry<K, V>> biConsumer) LockedStreamImpl.invokeAll
(BiFunction<Cache<K, V>, ? super CacheEntry<K, V>, R> biFunction) TxLockedStreamImpl.invokeAll
(BiFunction<Cache<K, V>, ? super CacheEntry<K, V>, R> biFunction) -
Uses of Cache in org.infinispan.tasks
Modifier and TypeMethodDescriptionThe cache against which this task will be executed. -
Uses of Cache in org.infinispan.upgrade
Modifier and TypeMethodDescriptionvoid
TargetMigrator.connectSource
(Cache<Object, Object> cache, StoreConfiguration configuration) Connects the target cluster to the source cluster through a Remote Store.void
TargetMigrator.disconnectSource
(Cache<Object, Object> cache) Disconnects the target from the source.boolean
TargetMigrator.isConnected
(Cache<Object, Object> cache) Check if a cluster is connected to other for doing rolling upgradeslong
TargetMigrator.synchronizeData
(Cache<Object, Object> cache) Performs the synchronization of data between source and targetlong
TargetMigrator.synchronizeData
(Cache<Object, Object> cache, int readBatch, int threads) Performs the synchronization of data between source and target -
Uses of Cache in org.infinispan.util
Modifier and TypeMethodDescription<K,
V> void AbstractDelegatingCacheStream.forEach
(BiConsumer<Cache<K, V>, ? super R> action) ModifierConstructorDescriptionDataContainerRemoveIterator
(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.
BasicCache.continuousQuery()
instead.