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 |
Distributed Executor APIs (deprecated)
|
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 API.
|
org.infinispan.notifications.cachelistener.event |
Cache -specific listener events |
org.infinispan.persistence |
Persistence API.
|
org.infinispan.persistence.spi |
The Persistence SPI.
|
org.infinispan.query |
Query API.
|
org.infinispan.security |
Security API.
|
org.infinispan.stream |
Cache stream processing.
|
org.infinispan.tree |
TreeCache API.
|
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 |
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.
|
Constructor and Description |
---|
KeyAffinityServiceImpl(Executor executor,
Cache<? extends K,?> cache,
KeyGenerator<? extends K> keyGenerator,
int bufferSize,
Collection<Address> filter,
boolean start)
Deprecated.
|
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> |
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> |
DefaultCacheManager.internalGetCache(String cacheName,
String configurationName) |
Modifier and Type | Method and Description |
---|---|
Cache<K,V> |
Event.getCache() |
Modifier and Type | Method and Description |
---|---|
Cache |
InitializationContextImpl.getCache() |
Constructor and Description |
---|
InitializationContextImpl(StoreConfiguration configuration,
Cache cache,
StreamingMarshaller marshaller,
TimeService timeService,
ByteBufferFactory byteBufferFactory,
MarshalledEntryFactory mef) |
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) |
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 |
---|---|
Cache<?,?> |
TreeCache.getCache() |
Modifier and Type | Method and Description |
---|---|
<K,V> TreeCache<K,V> |
TreeCacheFactory.createTreeCache(Cache<K,V> cache)
Creates a TreeCache instance by taking in a
Cache as a parameter |
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.