Package | Description |
---|---|
org.infinispan.commands |
Commands that operate on the cache, either locally or remotely.
|
org.infinispan.stream.impl | |
org.infinispan.stream.impl.tx |
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) |
Modifier and Type | Class and Description |
---|---|
class |
ClusterStreamManagerImpl<K>
Cluster stream manager that sends all requests using the
RpcManager to do the underlying communications. |
class |
PartitionAwareClusterStreamManager<K>
Cluster stream manager that also pays attention to partition status and properly closes iterators and throws
exceptions when the availability mode changes.
|
Modifier and Type | Field and Description |
---|---|
protected ClusterStreamManager |
AbstractCacheStream.csm |
protected ClusterStreamManager |
StreamResponseCommand.csm |
Modifier and Type | Method and Description |
---|---|
void |
StreamResponseCommand.inject(ClusterStreamManager csm) |
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 | Class and Description |
---|---|
class |
TxClusterStreamManager<K>
This is a delegating cluster stream manager that sends all calls to the underlying cluster stream manager.
|
Constructor and Description |
---|
TxClusterStreamManager(ClusterStreamManager<K> manager,
LocalTxInvocationContext ctx,
ConsistentHash hash) |
Copyright © 2023 JBoss, a division of Red Hat. All rights reserved.