Package | Description |
---|---|
org.infinispan.cache.impl | |
org.infinispan.commands |
Commands that operate on the cache, either locally or remotely.
|
org.infinispan.commands.read | |
org.infinispan.commands.remote |
Meta-commands that wrap other commands for remote execution.
|
org.infinispan.commands.write |
Commands that alter the state of the cache.
|
org.infinispan.container |
Data containers which store cache entries.
|
org.infinispan.interceptors |
Infinispan is designed around a set of interceptors around a data container.
|
org.infinispan.interceptors.compat | |
org.infinispan.iteration.impl |
Provides Infinispan-specific implementation details iterating over entries in the cache, specifically optimized for
distributed caches.
|
org.infinispan.persistence |
This package contains stores, which are used for overflow or persistence.
|
org.infinispan.persistence.remote |
HotRod-based
AdvancedLoadWriteStore |
org.infinispan.persistence.util | |
org.infinispan.statetransfer |
Transfer of state to new caches in a cluster.
|
Modifier and Type | Method and Description |
---|---|
void |
SimpleCacheImpl.injectDependencies(ComponentRegistry componentRegistry,
Configuration configuration,
EmbeddedCacheManager cacheManager,
DataContainer dataContainer,
CacheNotifier cacheNotifier,
TimeService timeService,
InternalEntryFactory entryFactory) |
Modifier and Type | Method and Description |
---|---|
void |
CommandsFactoryImpl.setupDependencies(DataContainer container,
CacheNotifier<Object,Object> notifier,
Cache<Object,Object> cache,
InterceptorChain interceptorChain,
DistributionManager distributionManager,
InvocationContextFactory icf,
TransactionTable txTable,
Configuration configuration,
Map<Byte,ModuleCommandInitializer> moduleCommandInitializers,
RecoveryManager recoveryManager,
StateProvider stateProvider,
StateConsumer stateConsumer,
LockManager lockManager,
InternalEntryFactory entryFactory,
MapReduceManager mapReduceManager,
StateTransferManager stm,
BackupSender backupSender,
CancellationService cancellationService,
TimeService timeService,
XSiteStateProvider xSiteStateProvider,
XSiteStateConsumer xSiteStateConsumer,
XSiteStateTransferManager xSiteStateTransferManager,
EntryRetriever entryRetriever,
GroupManager groupManager,
PartitionHandlingManager partitionHandlingManager,
LocalStreamManager localStreamManager,
ClusterStreamManager clusterStreamManager,
ClusteringDependentLogic clusteringDependentLogic,
ExternalizerTable externalizerTable) |
Constructor and Description |
---|
GetAllCommand(Collection<?> keys,
Set<Flag> flags,
boolean returnEntries,
InternalEntryFactory entryFactory) |
GetCacheEntryCommand(Object key,
Set<Flag> flags,
InternalEntryFactory entryFactory) |
Modifier and Type | Method and Description |
---|---|
void |
ClusteredGetAllCommand.init(InvocationContextFactory icf,
CommandsFactory commandsFactory,
InternalEntryFactory entryFactory,
InterceptorChain interceptorChain,
TransactionTable txTable,
Equivalence<? super K> keyEquivalence) |
void |
ClusteredGetCommand.initialize(InvocationContextFactory icf,
CommandsFactory commandsFactory,
InternalEntryFactory entryFactory,
InterceptorChain interceptorChain,
DistributionManager distributionManager,
TransactionTable txTable,
Equivalence keyEquivalence) |
Constructor and Description |
---|
EvictCommand(Object key,
CacheNotifier notifier,
Set<Flag> flags,
CommandInvocationId commandInvocationId,
InternalEntryFactory factory) |
Modifier and Type | Class and Description |
---|---|
class |
InternalEntryFactoryImpl
An implementation that generates non-versioned entries
|
Modifier and Type | Field and Description |
---|---|
protected InternalEntryFactory |
DefaultDataContainer.entryFactory |
Modifier and Type | Method and Description |
---|---|
InternalCacheEntry<K,V> |
DataContainer.ComputeAction.compute(K key,
InternalCacheEntry<K,V> oldEntry,
InternalEntryFactory factory)
Computes the new value for the key.
|
void |
DefaultDataContainer.initialize(EvictionManager evictionManager,
PassivationManager passivator,
InternalEntryFactory entryFactory,
ActivationManager activator,
PersistenceManager clm,
TimeService timeService,
CacheNotifier cacheNotifier,
ExpirationManager<K,V> expirationManager) |
Modifier and Type | Method and Description |
---|---|
protected void |
CacheWriterInterceptor.init(PersistenceManager pm,
InternalEntryFactory entryFactory,
TransactionManager transactionManager,
StreamingMarshaller marshaller)
Deprecated.
|
protected void |
MarshalledValueInterceptor.inject(StreamingMarshaller marshaller,
InternalEntryFactory entryFactory,
Cache<K,V> cache)
Deprecated.
|
void |
GroupingInterceptor.injectDependencies(CacheNotifier<?,?> cacheNotifier,
GroupManager groupManager,
InternalEntryFactory factory,
Configuration configuration)
Deprecated.
|
protected void |
CacheLoaderInterceptor.injectDependencies(PersistenceManager clm,
EntryFactory entryFactory,
CacheNotifier notifier,
TimeService timeService,
InternalEntryFactory iceFactory,
DataContainer<K,V> dataContainer,
GroupManager groupManager,
ExecutorService persistenceExecutor,
Cache<K,V> cache)
Deprecated.
|
Constructor and Description |
---|
KeyListener(String groupName,
GroupManager groupManager,
InternalEntryFactory factory) |
Modifier and Type | Method and Description |
---|---|
protected void |
BaseTypeConverterInterceptor.init(InternalEntryFactory entryFactory,
VersionGenerator versionGenerator,
Cache<K,V> cache)
Deprecated.
|
Constructor and Description |
---|
TypeConverterStream(CacheStream<?> stream,
TypeConverter<Object,Object,Object,Object> converter,
InternalEntryFactory entryFactory) |
Modifier and Type | Field and Description |
---|---|
protected InternalEntryFactory |
LocalEntryRetriever.entryFactory |
Modifier and Type | Method and Description |
---|---|
void |
LocalEntryRetriever.inject(DataContainer<K,V> dataContainer,
PersistenceManager persistenceManager,
ExecutorService executorService,
TimeService timeService,
InternalEntryFactory entryFactory,
Cache<K,V> cache,
Configuration config,
ComponentRegistry componentRegistry) |
Modifier and Type | Method and Description |
---|---|
static <K,V> InternalCacheEntry<K,V> |
PersistenceUtil.convert(MarshalledEntry<K,V> loaded,
InternalEntryFactory factory) |
static <K,V> Set<InternalCacheEntry> |
PersistenceUtil.toEntrySet(AdvancedCacheLoader<K,V> acl,
KeyFilter<? super K> filter,
InternalEntryFactory ief) |
Modifier and Type | Method and Description |
---|---|
void |
RemoteStore.setInternalCacheEntryFactory(InternalEntryFactory iceFactory) |
Constructor and Description |
---|
PersistenceManagerCloseableSupplier(Executor executor,
PersistenceManager manager,
InternalEntryFactory factory,
KeyFilter<K> filter,
long timeout,
TimeUnit unit,
int maxQueue) |
Modifier and Type | Method and Description |
---|---|
void |
StateProviderImpl.init(Cache cache,
ExecutorService executorService,
Configuration configuration,
RpcManager rpcManager,
CommandsFactory commandsFactory,
ClusterCacheNotifier clusterCacheNotifier,
PersistenceManager persistenceManager,
DataContainer dataContainer,
TransactionTable transactionTable,
StateTransferLock stateTransferLock,
StateConsumer stateConsumer,
InternalEntryFactory entryFactory) |
Constructor and Description |
---|
OutboundTransferTask(Address destination,
Set<Integer> segments,
int stateTransferChunkSize,
int topologyId,
ConsistentHash readCh,
StateProviderImpl stateProvider,
DataContainer dataContainer,
PersistenceManager persistenceManager,
RpcManager rpcManager,
CommandsFactory commandsFactory,
InternalEntryFactory ef,
long timeout,
String cacheName) |
Copyright © 2021 JBoss, a division of Red Hat. All rights reserved.