Package | Description |
---|---|
org.infinispan.container |
Data containers which store cache entries.
|
org.infinispan.container.entries |
Entries which are stored in data containers.
|
org.infinispan.distexec.mapreduce |
Map/Reduce APIs
|
org.infinispan.eviction.impl | |
org.infinispan.expiration.impl | |
org.infinispan.interceptors |
Infinispan is designed around a set of interceptors around a data container.
|
org.infinispan.interceptors.locking | |
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.manager | |
org.infinispan.persistence.util | |
org.infinispan.statetransfer |
Transfer of state to new caches in a cluster.
|
org.infinispan.transaction.impl | |
org.infinispan.xsite.statetransfer |
Modifier and Type | Method and Description |
---|---|
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 |
---|---|
boolean |
ClusteredRepeatableReadEntry.performWriteSkewCheck(DataContainer container,
PersistenceManager persistenceManager,
TxInvocationContext ctx,
EntryVersion versionSeen,
VersionGenerator versionGenerator,
TimeService timeService) |
Modifier and Type | Method and Description |
---|---|
void |
MapReduceManagerImpl.init(EmbeddedCacheManager cacheManager,
PersistenceManager persistenceManager,
ExecutorService asyncTransportExecutor,
ClusteringDependentLogic cdl,
TimeService timeService,
Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
void |
PassivationManagerImpl.inject(PersistenceManager persistenceManager,
CacheNotifier notifier,
Configuration cfg,
DataContainer container,
TimeService timeService,
MarshalledEntryFactory marshalledEntryFactory,
DistributionManager distributionManager) |
void |
ActivationManagerImpl.inject(PersistenceManager clm,
Configuration cfg,
ClusteringDependentLogic cdl) |
Modifier and Type | Field and Description |
---|---|
protected PersistenceManager |
ExpirationManagerImpl.persistenceManager |
Modifier and Type | Method and Description |
---|---|
void |
ExpirationManagerImpl.initialize(ScheduledExecutorService executor,
Cache<K,V> cache,
Configuration cfg,
DataContainer<K,V> dataContainer,
PersistenceManager persistenceManager,
CacheNotifier<K,V> cacheNotifier,
TimeService timeService) |
Modifier and Type | Field and Description |
---|---|
protected PersistenceManager |
CacheLoaderInterceptor.persistenceManager
Deprecated.
|
protected PersistenceManager |
CacheWriterInterceptor.persistenceManager
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected void |
CacheWriterInterceptor.init(PersistenceManager pm,
InternalEntryFactory entryFactory,
TransactionManager transactionManager,
StreamingMarshaller marshaller)
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.
|
Modifier and Type | Field and Description |
---|---|
protected PersistenceManager |
ClusteringDependentLogic.AbstractClusteringDependentLogic.persistenceManager |
Modifier and Type | Method and Description |
---|---|
void |
ClusteringDependentLogic.AbstractClusteringDependentLogic.init(DataContainer<Object,Object> dataContainer,
CacheNotifier<Object,Object> notifier,
Configuration configuration,
CommitManager commitManager,
PersistenceManager persistenceManager,
TimeService timeService,
FunctionalNotifier<Object,Object> functionalNotifier) |
Modifier and Type | Field and Description |
---|---|
protected PersistenceManager |
LocalEntryRetriever.persistenceManager |
Modifier and Type | Method and Description |
---|---|
void |
DistributedEntryRetriever.initialize(DistributionManager distributionManager,
PersistenceManager persistenceManager,
CommandsFactory commandsFactory,
RpcManager rpcManager,
ExecutorService remoteExecutorService) |
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 MarshalledEntry |
PersistenceUtil.loadAndCheckExpiration(PersistenceManager persistenceManager,
Object key,
InvocationContext context,
TimeService timeService) |
static <K,V> InternalCacheEntry<K,V> |
PersistenceUtil.loadAndStoreInDataContainer(DataContainer<K,V> dataContainer,
PersistenceManager persistenceManager,
K key,
InvocationContext ctx,
TimeService timeService,
AtomicReference<Boolean> isLoaded) |
Modifier and Type | Class and Description |
---|---|
class |
PersistenceManagerImpl |
class |
PersistenceManagerStub |
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) |
void |
StateConsumerImpl.init(Cache cache,
ExecutorService stateTransferExecutor,
StateTransferManager stateTransferManager,
InterceptorChain interceptorChain,
InvocationContextFactory icf,
Configuration configuration,
RpcManager rpcManager,
TransactionManager transactionManager,
CommandsFactory commandsFactory,
PersistenceManager persistenceManager,
DataContainer<Object,Object> dataContainer,
TransactionTable transactionTable,
StateTransferLock stateTransferLock,
CacheNotifier cacheNotifier,
TotalOrderManager totalOrderManager,
BlockingTaskAwareExecutorService remoteCommandsExecutor,
CommitManager commitManager) |
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) |
Modifier and Type | Method and Description |
---|---|
static EntryVersionsMap |
WriteSkewHelper.performTotalOrderWriteSkewCheckAndReturnNewVersions(VersionedPrepareCommand prepareCommand,
DataContainer dataContainer,
PersistenceManager persistenceManager,
VersionGenerator versionGenerator,
TxInvocationContext context,
WriteSkewHelper.KeySpecificLogic ksl,
TimeService timeService) |
static EntryVersionsMap |
WriteSkewHelper.performWriteSkewCheckAndReturnNewVersions(VersionedPrepareCommand prepareCommand,
DataContainer dataContainer,
PersistenceManager persistenceManager,
VersionGenerator versionGenerator,
TxInvocationContext context,
WriteSkewHelper.KeySpecificLogic ksl,
TimeService timeService) |
Modifier and Type | Method and Description |
---|---|
void |
XSiteStateProviderImpl.inject(DataContainer dataContainer,
PersistenceManager persistenceManager,
RpcManager rpcManager,
ClusteringDependentLogic clusteringDependentLogic,
CommandsFactory commandsFactory,
ExecutorService executorService,
Configuration configuration,
XSiteStateTransferManager xSiteStateTransferManager,
StateTransferLock stateTransferLock) |
Copyright © 2020 JBoss, a division of Red Hat. All rights reserved.