Package | Description |
---|---|
org.infinispan |
This is the core of Infinispan, a distributed, transactional, highly scalable data grid
platform.
|
org.infinispan.cache.impl | |
org.infinispan.factories |
Factories are internal components used to create other components based on a cache's
configuration.
|
org.infinispan.filter |
Provides capabilities around filtering and converting entries that are found in the cache or cache store/loader.
|
org.infinispan.interceptors |
Infinispan is designed around a set of interceptors around a data container.
|
org.infinispan.iteration.impl |
Provides Infinispan-specific implementation details iterating over entries in the cache, specifically optimized for
distributed caches.
|
org.infinispan.lifecycle |
Component lifecycle.
|
org.infinispan.notifications.cachelistener.filter |
Cache -specific notifications and eventing filtering classes. |
org.infinispan.security.actions | |
org.infinispan.security.impl | |
org.infinispan.stream.impl | |
org.infinispan.stream.impl.intops | |
org.infinispan.stream.impl.intops.object | |
org.infinispan.stream.impl.local | |
org.infinispan.stream.impl.termop | |
org.infinispan.stream.impl.termop.object | |
org.infinispan.stream.impl.termop.primitive | |
org.infinispan.stream.impl.tx |
Modifier and Type | Method and Description |
---|---|
ComponentRegistry |
AdvancedCache.getComponentRegistry() |
Modifier and Type | Field and Description |
---|---|
protected ComponentRegistry |
CacheImpl.componentRegistry |
Modifier and Type | Method and Description |
---|---|
ComponentRegistry |
SimpleCacheImpl.getComponentRegistry() |
ComponentRegistry |
AbstractDelegatingAdvancedCache.getComponentRegistry() |
ComponentRegistry |
CacheImpl.getComponentRegistry() |
Modifier and Type | Method and Description |
---|---|
void |
SimpleCacheImpl.injectDependencies(ComponentRegistry componentRegistry,
Configuration configuration,
EmbeddedCacheManager cacheManager,
DataContainer dataContainer,
CacheNotifier cacheNotifier,
TimeService timeService,
InternalEntryFactory entryFactory) |
void |
CacheImpl.injectDependencies(EvictionManager evictionManager,
ExpirationManager expirationManager,
InvocationContextFactory invocationContextFactory,
InvocationContextContainer icc,
CommandsFactory commandsFactory,
InterceptorChain interceptorChain,
Configuration configuration,
CacheNotifier notifier,
ComponentRegistry componentRegistry,
TransactionManager transactionManager,
BatchContainer batchContainer,
RpcManager rpcManager,
DataContainer dataContainer,
org.infinispan.commons.marshall.StreamingMarshaller marshaller,
DistributionManager distributionManager,
EmbeddedCacheManager cacheManager,
ExecutorService asyncExecutor,
TransactionTable txTable,
RecoveryManager recoveryManager,
TransactionCoordinator txCoordinator,
LockManager lockManager,
AuthorizationManager authorizationManager,
GlobalConfiguration globalCfg,
PartitionHandlingManager partitionHandlingManager,
LocalTopologyManager localTopologyManager) |
Modifier and Type | Field and Description |
---|---|
protected ComponentRegistry |
AbstractNamedCacheComponentFactory.componentRegistry |
Modifier and Type | Method and Description |
---|---|
ComponentRegistry |
GlobalComponentRegistry.getNamedComponentRegistry(String name) |
Modifier and Type | Method and Description |
---|---|
static InterceptorChainFactory |
InterceptorChainFactory.getInstance(ComponentRegistry componentRegistry,
Configuration configuration) |
void |
GlobalComponentRegistry.registerNamedComponentRegistry(ComponentRegistry componentRegistry,
String name) |
Constructor and Description |
---|
BootstrapFactory(AdvancedCache<?,?> advancedCache,
Configuration configuration,
ComponentRegistry componentRegistry) |
Modifier and Type | Method and Description |
---|---|
protected void |
KeyValueFilterAsKeyFilter.injectDependencies(ComponentRegistry cr) |
protected void |
KeyFilterAsKeyValueFilter.injectDependencies(ComponentRegistry cr) |
protected void |
CompositeKeyFilter.injectDependencies(ComponentRegistry cr) |
protected void |
CompositeKeyValueFilter.injectDependencies(ComponentRegistry cr) |
Modifier and Type | Method and Description |
---|---|
void |
InvocationContextInterceptor.init(ComponentRegistry componentRegistry,
TransactionTable txTable,
InvocationContextContainer invocationContextContainer)
Deprecated.
|
Modifier and Type | Field and Description |
---|---|
protected ComponentRegistry |
LocalEntryRetriever.componentRegistry |
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 |
---|---|
void |
AbstractModuleLifecycle.cacheStarted(ComponentRegistry cr,
String cacheName) |
void |
ModuleLifecycle.cacheStarted(ComponentRegistry cr,
String cacheName) |
void |
AbstractModuleLifecycle.cacheStarting(ComponentRegistry cr,
Configuration configuration,
String cacheName) |
void |
ModuleLifecycle.cacheStarting(ComponentRegistry cr,
Configuration configuration,
String cacheName) |
void |
AbstractModuleLifecycle.cacheStopped(ComponentRegistry cr,
String cacheName) |
void |
ModuleLifecycle.cacheStopped(ComponentRegistry cr,
String cacheName) |
void |
AbstractModuleLifecycle.cacheStopping(ComponentRegistry cr,
String cacheName) |
void |
ModuleLifecycle.cacheStopping(ComponentRegistry cr,
String cacheName) |
Modifier and Type | Method and Description |
---|---|
protected void |
CompositeCacheEventFilter.injectDependencies(ComponentRegistry cr) |
protected void |
CacheEventConverterAsConverter.injectDependencies(ComponentRegistry cr) |
protected void |
ConverterAsCacheEventConverter.injectDependencies(ComponentRegistry cr) |
protected void |
KeyValueFilterAsCacheEventFilter.injectDependencies(ComponentRegistry cr) |
protected void |
CacheEventFilterConverterAsKeyValueFilterConverter.injectDependencies(ComponentRegistry cr) |
protected void |
KeyFilterAsCacheEventFilter.injectDependencies(ComponentRegistry cr) |
protected void |
CacheEventFilterAsKeyValueFilter.injectDependencies(ComponentRegistry cr) |
Modifier and Type | Method and Description |
---|---|
ComponentRegistry |
GetCacheComponentRegistryAction.run() |
Modifier and Type | Method and Description |
---|---|
ComponentRegistry |
SecureCacheImpl.getComponentRegistry() |
Modifier and Type | Field and Description |
---|---|
protected ComponentRegistry |
AbstractCacheStream.registry |
Modifier and Type | Method and Description |
---|---|
void |
TerminalOperation.handleInjection(ComponentRegistry registry)
Handles injection of components for various intermediate and this operation.
|
void |
KeyTrackingTerminalOperation.handleInjection(ComponentRegistry registry)
Handles injection of components for various intermediate and this operation.
|
void |
LocalStreamManagerImpl.inject(Cache<K,V> cache,
ComponentRegistry registry,
StateTransferManager stm,
RpcManager rpc,
Configuration configuration,
CommandsFactory factory) |
Constructor and Description |
---|
AbstractCacheStream(Address localAddress,
boolean parallel,
DistributionManager dm,
Supplier<CacheStream<CacheEntry>> supplier,
ClusterStreamManager<Object> csm,
boolean includeLoader,
int distributedBatchSize,
Executor executor,
ComponentRegistry registry) |
DistributedCacheStream(Address localAddress,
boolean parallel,
DistributionManager dm,
Supplier<CacheStream<CacheEntry<K,V>>> supplier,
ClusterStreamManager csm,
boolean includeLoader,
int distributedBatchSize,
Executor executor,
ComponentRegistry registry)
Standard constructor requiring all pertinent information to properly utilize a distributed cache stream
|
DistributedCacheStream(Address localAddress,
boolean parallel,
DistributionManager dm,
Supplier<CacheStream<CacheEntry<K,V>>> supplier,
ClusterStreamManager csm,
boolean includeLoader,
int distributedBatchSize,
Executor executor,
ComponentRegistry registry,
Function<? super CacheEntry<K,V>,R> function)
Constructor that also allows a simple map method to be inserted first to change to another type.
|
Modifier and Type | Method and Description |
---|---|
default void |
IntermediateOperation.handleInjection(ComponentRegistry registry)
Handles injection of components for various dependencies that the intermediate operation has
|
Modifier and Type | Method and Description |
---|---|
void |
MapOperation.handleInjection(ComponentRegistry registry) |
Modifier and Type | Field and Description |
---|---|
protected ComponentRegistry |
AbstractLocalCacheStream.registry |
Constructor and Description |
---|
AbstractLocalCacheStream(AbstractLocalCacheStream.StreamSupplier<T> streamSupplier,
boolean parallel,
ComponentRegistry registry) |
LocalCacheStream(AbstractLocalCacheStream.StreamSupplier<R> streamSupplier,
boolean parallel,
ComponentRegistry registry) |
LocalDoubleCacheStream(AbstractLocalCacheStream.StreamSupplier streamSupplier,
boolean parallel,
ComponentRegistry registry) |
LocalIntCacheStream(AbstractLocalCacheStream.StreamSupplier streamSupplier,
boolean parallel,
ComponentRegistry registry) |
LocalLongCacheStream(AbstractLocalCacheStream.StreamSupplier streamSupplier,
boolean parallel,
ComponentRegistry registry) |
Modifier and Type | Method and Description |
---|---|
void |
BaseTerminalOperation.handleInjection(ComponentRegistry registry) |
Modifier and Type | Method and Description |
---|---|
void |
ForEachOperation.handleInjection(ComponentRegistry registry) |
Modifier and Type | Method and Description |
---|---|
void |
ForEachDoubleOperation.handleInjection(ComponentRegistry registry) |
void |
ForEachFlatMapDoubleOperation.handleInjection(ComponentRegistry registry) |
void |
ForEachFlatMapLongOperation.handleInjection(ComponentRegistry registry) |
void |
ForEachFlatMapIntOperation.handleInjection(ComponentRegistry registry) |
void |
ForEachLongOperation.handleInjection(ComponentRegistry registry) |
void |
ForEachIntOperation.handleInjection(ComponentRegistry registry) |
Constructor and Description |
---|
TxDistributedCacheStream(Address localAddress,
boolean parallel,
DistributionManager dm,
Supplier<CacheStream<CacheEntry<K,V>>> supplier,
TxClusterStreamManager<?> csm,
boolean includeLoader,
int distributedBatchSize,
Executor executor,
ComponentRegistry registry,
Function<? super CacheEntry<K,V>,R> function,
LocalTxInvocationContext ctx) |
TxDistributedCacheStream(Address localAddress,
boolean parallel,
DistributionManager dm,
Supplier<CacheStream<CacheEntry<K,V>>> supplier,
TxClusterStreamManager<?> csm,
boolean includeLoader,
int distributedBatchSize,
Executor executor,
ComponentRegistry registry,
LocalTxInvocationContext ctx) |
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.