Package | Description |
---|---|
org.infinispan.configuration.global |
EmbeddedCacheManager configuration |
org.infinispan.interceptors.locking |
Interceptors dealing with locking.
|
org.infinispan.manager |
Cache manager API.
|
org.infinispan.manager.impl | |
org.infinispan.remoting.rpc |
Remote Procedure Call (RPC) interfaces and components used to invoke remote methods on cache instances.
|
org.infinispan.remoting.transport |
Transports handle the low-level networking, used by the remoting components.
|
org.infinispan.remoting.transport.jgroups |
A transport implementation based on JGroups.
|
org.infinispan.topology |
Modifier and Type | Method and Description |
---|---|
Transport |
TransportConfigurationBuilder.getTransport() |
Transport |
TransportConfiguration.transport() |
Transport |
JGroupsConfiguration.transport() |
Modifier and Type | Method and Description |
---|---|
TransportConfigurationBuilder |
TransportConfigurationBuilder.transport(Transport transport)
Class that represents a network transport.
|
JGroupsConfigurationBuilder |
JGroupsConfigurationBuilder.transport(Transport transport) |
Modifier and Type | Method and Description |
---|---|
void |
ClusteringDependentLogic.LocalLogic.init(Transport transport,
Configuration configuration,
KeyPartitioner keyPartitioner) |
Modifier and Type | Method and Description |
---|---|
Transport |
DefaultCacheManager.getTransport() |
Transport |
EmbeddedCacheManager.getTransport()
Deprecated.
Since 10.0, please use
EmbeddedCacheManager.getAddress() , EmbeddedCacheManager.getMembers() , EmbeddedCacheManager.getCoordinator() |
Modifier and Type | Method and Description |
---|---|
Transport |
AbstractDelegatingEmbeddedCacheManager.getTransport() |
Modifier and Type | Method and Description |
---|---|
static ClusterExecutor |
ClusterExecutors.allSubmissionExecutor(Predicate<? super Address> predicate,
EmbeddedCacheManager manager,
Transport transport,
long time,
TimeUnit unit,
Executor localExecutor,
ScheduledExecutorService timeoutExecutor) |
static ClusterExecutor |
ClusterExecutors.singleNodeSubmissionExecutor(Predicate<? super Address> predicate,
EmbeddedCacheManager manager,
Transport transport,
long time,
TimeUnit unit,
Executor localExecutor,
ScheduledExecutorService timeoutExecutor,
int failOverCount) |
Modifier and Type | Method and Description |
---|---|
Transport |
RpcManager.getTransport() |
Transport |
RpcManagerImpl.getTransport() |
Modifier and Type | Method and Description |
---|---|
void |
RpcManagerImpl.setTransport(Transport t) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractDelegatingTransport
Designed to be overwrite.
|
class |
AbstractTransport
Deprecated.
Since 9.1, please implement
Transport directly. |
Modifier and Type | Field and Description |
---|---|
protected Transport |
AbstractDelegatingTransport.actual |
Modifier and Type | Method and Description |
---|---|
Transport |
AbstractDelegatingTransport.getDelegate() |
Constructor and Description |
---|
AbstractDelegatingTransport(Transport actual) |
Modifier and Type | Class and Description |
---|---|
class |
JGroupsTransport
An encapsulation of a JGroups transport.
|
Modifier and Type | Method and Description |
---|---|
void |
TopologyManagementHelper.executeOnClusterAsync(Transport transport,
ReplicableCommand command) |
<T> CompletionStage<T> |
TopologyManagementHelper.executeOnClusterSync(Transport transport,
ReplicableCommand command,
int timeout,
ResponseCollector<T> responseCollector) |
CompletionStage<Object> |
TopologyManagementHelper.executeOnCoordinator(Transport transport,
ReplicableCommand command,
long timeoutMillis) |
void |
TopologyManagementHelper.executeOnCoordinatorAsync(Transport transport,
AbstractCacheControlCommand command) |
Constructor and Description |
---|
ClusterCacheStatus(EmbeddedCacheManager cacheManager,
String cacheName,
AvailabilityStrategy availabilityStrategy,
RebalanceType rebalanceType,
ClusterTopologyManagerImpl clusterTopologyManager,
Transport transport,
PersistentUUIDManager persistentUUIDManager,
EventLogManager eventLogManager,
Optional<ScopedPersistentState> state,
boolean resolveConflictsOnMerge) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.