Package | Description |
---|---|
org.infinispan.commands |
Commands that operate on the cache, either locally or remotely.
|
org.infinispan.commands.read | |
org.infinispan.container |
Data containers which store cache entries.
|
org.infinispan.distexec.mapreduce | |
org.infinispan.distribution |
Classes relating to the distributed cache mode.
|
org.infinispan.eviction |
Classes related to eviction.
|
org.infinispan.executors |
Implementations of different executors used for asynchronous operation.
|
org.infinispan.factories |
Factories are internal components used to create other components based on a cache's
configuration.
|
org.infinispan.interceptors |
Infinispan is designed around a set of interceptors around a data container.
|
org.infinispan.interceptors.compat | |
org.infinispan.interceptors.locking | |
org.infinispan.persistence |
This package contains stores, which are used for overflow or persistence.
|
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.manager | |
org.infinispan.persistence.spi | |
org.infinispan.persistence.support | |
org.infinispan.query.impl.massindex | |
org.infinispan.remoting.rpc |
Remote Procedure Call (RPC) interfaces and components used to invoke remote methods on cache instances.
|
org.infinispan.remoting.transport.jgroups |
A transport implementation based on JGroups.
|
org.infinispan.topology | |
org.infinispan.transaction |
JTA transaction support.
|
org.infinispan.upgrade | |
org.infinispan.util |
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.
|
org.infinispan.util.concurrent |
Thread-safe containers and other concurrency-related utilities, designed to supplement JDK concurrency utilities
and containers.
|
org.infinispan.util.concurrent.locks |
Lock and synchronization related classes, tools and utilities.
|
org.infinispan.xsite |
Modifier and Type | Method and Description |
---|---|
void |
CommandsFactoryImpl.setupDependencies(DataContainer container,
CacheNotifier 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) |
Modifier and Type | Method and Description |
---|---|
static Set<InternalCacheEntry> |
EntrySetCommand.createFilteredEntrySet(Set<InternalCacheEntry> entries,
InvocationContext ctx,
TimeService timeService,
InternalEntryFactory entryFactory) |
Constructor and Description |
---|
EntrySetCommand(DataContainer container,
InternalEntryFactory internalEntryFactory,
TimeService timeService,
Set<Flag> flags) |
ExpiredFilteredValues(Set<InternalCacheEntry> entrySet,
TimeService timeService) |
ValuesCommand(DataContainer container,
TimeService timeService,
Set<Flag> flags) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultDataContainer.initialize(EvictionManager evictionManager,
PassivationManager passivator,
InternalEntryFactory entryFactory,
ActivationManager activator,
PersistenceManager clm,
TimeService timeService) |
void |
InternalEntryFactoryImpl.injectTimeService(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 |
L1ManagerImpl.init(Configuration configuration,
RpcManager rpcManager,
CommandsFactory commandsFactory,
ExecutorService asyncTransportExecutor,
ScheduledExecutorService scheduledExecutor,
TimeService timeService) |
Modifier and Type | Method and Description |
---|---|
void |
EvictionManagerImpl.initialize(ScheduledExecutorService executor,
Cache cache,
Configuration cfg,
DataContainer dataContainer,
PersistenceManager persistenceManager,
CacheNotifier cacheNotifier,
TimeService timeService) |
void |
PassivationManagerImpl.inject(PersistenceManager persistenceManager,
CacheNotifier notifier,
Configuration cfg,
DataContainer container,
TimeService timeService,
MarshalledEntryFactory marshalledEntryFactory) |
Constructor and Description |
---|
LazyInitializingBlockingTaskAwareExecutorService(ExecutorFactory factory,
Properties executorProperties,
TimeService timeService) |
Modifier and Type | Method and Description |
---|---|
TimeService |
ComponentRegistry.getTimeService() |
abstract TimeService |
AbstractComponentRegistry.getTimeService() |
TimeService |
GlobalComponentRegistry.getTimeService() |
Modifier and Type | Method and Description |
---|---|
protected void |
CacheLoaderInterceptor.injectDependencies(PersistenceManager clm,
EntryFactory entryFactory,
CacheNotifier notifier,
TimeService timeService,
InternalEntryFactory iceFactory) |
void |
CacheMgmtInterceptor.setDependencies(DataContainer dataContainer,
TimeService timeService) |
Modifier and Type | Method and Description |
---|---|
protected void |
BaseTypeConverterInterceptor.init(InternalEntryFactory entryFactory,
VersionGenerator versionGenerator,
TimeService timeService) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractTxLockingInterceptor.setDependencies(TransactionTable txTable,
RpcManager rpcManager,
TimeService timeService) |
Modifier and Type | Method and Description |
---|---|
TimeService |
InitializationContextImpl.getTimeService() |
Constructor and Description |
---|
InitializationContextImpl(StoreConfiguration configuration,
Cache cache,
StreamingMarshaller marshaller,
TimeService timeService,
ByteBufferFactory byteBufferFactory,
MarshalledEntryFactory mef) |
Modifier and Type | Method and Description |
---|---|
TimeService |
InitialisationContextDelegate.getTimeService() |
Modifier and Type | Method and Description |
---|---|
void |
PersistenceManagerImpl.inject(AdvancedCache<Object,Object> cache,
StreamingMarshaller marshaller,
Configuration configuration,
TransactionManager transactionManager,
TimeService timeService,
ExecutorService persistenceExecutor,
ByteBufferFactory byteBufferFactory,
MarshalledEntryFactory marshalledEntryFactory) |
Modifier and Type | Method and Description |
---|---|
TimeService |
InitializationContext.getTimeService() |
Modifier and Type | Method and Description |
---|---|
boolean |
Bucket.contains(Object key,
TimeService timeService) |
MarshalledEntry |
Bucket.getEntry(Object key,
TimeService timeService) |
Map<Object,MarshalledEntry> |
Bucket.getStoredEntries(AdvancedCacheLoader.KeyFilter filter,
TimeService timeService) |
Set<Object> |
Bucket.removeExpiredEntries(TimeService timeService) |
Constructor and Description |
---|
DefaultMassIndexerProgressMonitor(int logAfterNumberOfDocuments,
TimeService timeService)
Logs progress of indexing job every
logAfterNumberOfDocuments
documents written. |
DefaultMassIndexerProgressMonitor(TimeService timeService)
Logs progress of indexing job every 50 documents written.
|
Modifier and Type | Method and Description |
---|---|
void |
RpcManagerImpl.injectDependencies(Transport t,
Cache cache,
Configuration cfg,
ReplicationQueue replicationQueue,
CommandsFactory cf,
ExecutorService e,
LocalTopologyManager localTopologyManager,
StateTransferManager stateTransferManager,
TimeService timeService) |
Modifier and Type | Method and Description |
---|---|
void |
JGroupsTransport.initialize(StreamingMarshaller marshaller,
ExecutorService asyncExecutor,
ExecutorService remoteCommandsExecutor,
InboundInvocationHandler inboundInvocationHandler,
CacheManagerNotifier notifier,
GlobalComponentRegistry gcr,
BackupReceiverRepository backupReceiverRepository,
TimeService timeService)
Initializes the transport with global cache configuration and transport-specific properties.
|
Constructor and Description |
---|
JGroupsBackupResponse(Map<XSiteBackup,Future<Object>> syncBackupCalls,
TimeService timeService) |
Modifier and Type | Method and Description |
---|---|
void |
LocalTopologyManagerImpl.inject(Transport transport,
ExecutorService asyncTransportExecutor,
GlobalComponentRegistry gcr,
TimeService timeService) |
Modifier and Type | Method and Description |
---|---|
void |
TransactionTable.initialize(RpcManager rpcManager,
Configuration configuration,
InvocationContextFactory icf,
InterceptorChain invoker,
CacheNotifier notifier,
TransactionFactory gtf,
TransactionCoordinator txCoordinator,
TransactionSynchronizationRegistry transactionSynchronizationRegistry,
CommandsFactory commandsFactory,
ClusteringDependentLogic clusteringDependentLogic,
Cache cache,
TimeService timeService) |
Modifier and Type | Method and Description |
---|---|
void |
RollingUpgradeManager.initialize(Cache<Object,Object> cache,
TimeService timeService) |
Modifier and Type | Class and Description |
---|---|
class |
DefaultTimeService
The default implementation of
TimeService . |
Constructor and Description |
---|
BlockingTaskAwareExecutorServiceImpl(ExecutorService executorService,
TimeService timeService) |
Modifier and Type | Method and Description |
---|---|
void |
DeadlockDetectingLockManager.injectTimeService(TimeService timeService) |
Modifier and Type | Method and Description |
---|---|
void |
BackupSenderImpl.init(Cache cache,
Transport transport,
TransactionTable txTable,
GlobalConfiguration gc,
TimeService timeService) |
Constructor and Description |
---|
OfflineStatus(TakeOfflineConfiguration takeOfflineConfiguration,
TimeService timeService) |
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.