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.atomic |
This package contains the
AtomicMap interfaces and API that Infinispan exposes as building
blocks in creating other public interfaces such as the Tree API. |
org.infinispan.cache.impl | |
org.infinispan.distexec |
Distribute Executor APIs
|
org.infinispan.interceptors.base |
Base interceptors containing common, reusable behavior.
|
org.infinispan.io |
Provides Infinispan-specific input and output streams, buffers and related utilities.
|
org.infinispan.manager |
Cache manager package
|
org.infinispan.notifications.cachelistener.event |
Cache -specific listener events |
org.infinispan.persistence.jdbc.mixed |
This is a delegating CacheStore implementation that delegates either to a binary
or String based JDBC cache store depending on the key used.
|
org.infinispan.persistence.spi |
The Persistence SPI
|
org.infinispan.query |
Query API.
|
org.infinispan.query.continuous |
Functionality related to continuous query, which sends updates to the client based on the client
query when there are any changes to the data which match the original query.
|
org.infinispan.security |
The Security API
|
org.infinispan.stream |
This package contains various helper classes when using the
CacheStream or its various
classes. |
org.infinispan.tasks |
Classes and interfaces related to task execution
|
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 |
---|---|
<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 <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 |
Constructor and Description |
---|
AbstractDelegatingCache(Cache<K,V> cache)
Deprecated.
|
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.
|
Modifier and Type | Method and Description |
---|---|
static <MK,K,V> AtomicMap<K,V> |
AtomicMapLookup.getAtomicMap(Cache<MK,?> cache,
MK key)
Retrieves an atomic map from a given cache, stored under a given key.
|
static <MK,K,V> AtomicMap<K,V> |
AtomicMapLookup.getAtomicMap(Cache<MK,?> cache,
MK key,
boolean createIfAbsent)
Retrieves an atomic map from a given cache, stored under a given key.
|
static <MK,K,V> FineGrainedAtomicMap<K,V> |
AtomicMapLookup.getFineGrainedAtomicMap(Cache<MK,?> cache,
MK key)
Retrieves a fine grained atomic map from a given cache, stored under a given key.
|
static <MK,K,V> FineGrainedAtomicMap<K,V> |
AtomicMapLookup.getFineGrainedAtomicMap(Cache<MK,?> cache,
MK key,
boolean createIfAbsent)
Retrieves an atomic map from a given cache, stored under a given key.
|
static <MK,K,V> Map<K,V> |
AtomicMapLookup.getReadOnlyAtomicMap(Cache<MK,?> cache,
MK key)
Retrieves an atomic map from a given cache, stored under a given key, for reading only.
|
static <MK> void |
AtomicMapLookup.removeAtomicMap(Cache<MK,?> cache,
MK key)
Removes the atomic map associated with the given key from the underlying cache.
|
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.
|
Modifier and Type | Method and Description |
---|---|
static ExecutorService |
DefaultExecutorService.createLocalExecutor(Cache<?,?> masterCacheNode)
Deprecated.
|
void |
DistributedCallable.setEnvironment(Cache<K,V> cache,
Set<K> inputKeys)
Invoked by execution environment after DistributedCallable has been migrated for execution to
a specific Infinispan node.
|
Constructor and Description |
---|
DefaultExecutorService(Cache<?,?> masterCacheNode)
Deprecated.
Creates a new DefaultExecutorService given a master cache node for local task execution.
|
DefaultExecutorService(Cache<?,?> masterCacheNode,
ExecutorService localExecutorService)
Deprecated.
Creates a new DefaultExecutorService given a master cache node and an ExecutorService for
parallel execution of tasks ran on this node.
|
DefaultExecutorService(Cache<?,?> masterCacheNode,
ExecutorService localExecutorService,
boolean takeExecutorOwnership)
Deprecated.
Creates a new DefaultExecutorService given a master cache node and an ExecutorService for
parallel execution of task ran on this node.
|
Modifier and Type | Field and Description |
---|---|
protected Cache<?,?> |
BaseCustomInterceptor.cache
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected <K,V> Cache<K,V> |
CommandInterceptor.getCacheWithFlags(Cache<K,V> cache,
FlagAffectedCommand command)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected <K,V> Cache<K,V> |
CommandInterceptor.getCacheWithFlags(Cache<K,V> cache,
FlagAffectedCommand command)
Deprecated.
|
Modifier and Type | Field and Description |
---|---|
protected Cache<String,byte[]> |
GridFilesystem.data |
protected Cache<String,GridFile.Metadata> |
GridFilesystem.metadata |
Constructor and Description |
---|
GridFilesystem(Cache<String,byte[]> data,
Cache<String,GridFile.Metadata> metadata) |
GridFilesystem(Cache<String,byte[]> data,
Cache<String,GridFile.Metadata> metadata) |
GridFilesystem(Cache<String,byte[]> data,
Cache<String,GridFile.Metadata> metadata,
int defaultChunkSize)
Creates an instance.
|
GridFilesystem(Cache<String,byte[]> data,
Cache<String,GridFile.Metadata> metadata,
int defaultChunkSize)
Creates an instance.
|
Modifier and Type | Method and Description |
---|---|
<K,V> Cache<K,V> |
EmbeddedCacheManagerAdmin.createCache(String name,
Configuration configuration)
Creates a cache across the cluster.
|
<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> |
DefaultCacheManagerAdmin.createCache(String cacheName,
Configuration configuration) |
<K,V> Cache<K,V> |
DefaultCacheManager.createCache(String name,
Configuration 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> |
DefaultCacheManagerAdmin.createCache(String cacheName,
String template) |
<K,V> Cache<K,V> |
DefaultCacheManager.getCache()
Retrieves the default cache associated with this cache manager.
|
<K,V> Cache<K,V> |
CacheContainer.getCache()
This method overrides the underlying
CacheContainer.getCache() ,
to return a Cache instead of a BasicCache |
<K,V> Cache<K,V> |
DefaultCacheManager.getCache(String cacheName)
Retrieves a named cache from the system.
|
<K,V> Cache<K,V> |
CacheContainer.getCache(String cacheName)
This method overrides the underlying
CacheContainer.getCache(String) ,
to return a Cache instead of a BasicCache |
<K,V> Cache<K,V> |
EmbeddedCacheManager.getCache(String cacheName,
boolean createIfAbsent)
Retrieves a named cache from the system in the same way that
CacheContainer.getCache(String) does except that if offers the possibility for the
named cache not to be retrieved if it has not yet been started, or if
it's been removed after being started. |
<K,V> Cache<K,V> |
DefaultCacheManager.getCache(String cacheName,
boolean createIfAbsent) |
<K,V> Cache<K,V> |
EmbeddedCacheManager.getCache(String cacheName,
String configurationName)
Deprecated.
as of 9.0. Use
EmbeddedCacheManager.defineConfiguration(String, String, Configuration) and
CacheContainer.getCache(String) instead |
<K,V> Cache<K,V> |
DefaultCacheManager.getCache(String cacheName,
String configurationName) |
<K,V> Cache<K,V> |
EmbeddedCacheManager.getCache(String cacheName,
String configurationTemplate,
boolean createIfAbsent)
Deprecated.
|
<K,V> Cache<K,V> |
DefaultCacheManager.getCache(String cacheName,
String configurationTemplate,
boolean createIfAbsent) |
<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,
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> |
DefaultCacheManagerAdmin.getOrCreateCache(String cacheName,
String template) |
<K,V> Cache<K,V> |
DefaultCacheManager.internalGetCache(String cacheName,
String configurationName) |
Modifier and Type | Method and Description |
---|---|
Cache<K,V> |
Event.getCache() |
Modifier and Type | Method and Description |
---|---|
Cache |
InitialisationContextDelegate.getCache() |
Modifier and Type | Method and Description |
---|---|
Cache |
InitializationContext.getCache() |
Modifier and Type | Method and Description |
---|---|
static <K,V> ContinuousQuery<K,V> |
Search.getContinuousQuery(Cache<K,V> cache) |
static QueryFactory |
Search.getQueryFactory(Cache<?,?> cache) |
static SearchManager |
Search.getSearchManager(Cache<?,?> cache) |
Constructor and Description |
---|
ContinuousQuery(Cache<K,V> cache)
Deprecated.
|
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 |
---|---|
void |
CacheAware.injectCache(Cache<K,V> cache)
Method that is invoked when a cache is to be injected.
|
Modifier and Type | Method and Description |
---|---|
Optional<Cache<?,?>> |
TaskContext.getCache()
The default cache.
|
Modifier and Type | Method and Description |
---|---|
TaskContext |
TaskContext.cache(Cache<?,?> cache)
The cache against which this task will be executed.
|
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.