| Package | Description |
|---|---|
| org.infinispan.reactive.publisher.impl | |
| org.infinispan.remoting.rpc |
Remote Procedure Call (RPC) interfaces and components used to invoke remote methods on cache instances.
|
| org.infinispan.statetransfer |
Transfer of state to new caches in a cluster.
|
| Modifier and Type | Field and Description |
|---|---|
protected RpcOptions |
ClusterPublisherManagerImpl.rpcOptions |
| Modifier and Type | Method and Description |
|---|---|
RpcOptions |
RpcManager.getSyncRpcOptions() |
RpcOptions |
RpcManagerImpl.getSyncRpcOptions() |
default RpcOptions |
RpcManager.getTotalSyncRpcOptions() |
| Modifier and Type | Method and Description |
|---|---|
<T> CompletionStage<T> |
RpcManager.invokeCommand(Address target,
ReplicableCommand command,
ResponseCollector<T> collector,
RpcOptions rpcOptions)
Invoke a command on a single node and pass the response to a
ResponseCollector. |
<T> CompletionStage<T> |
RpcManagerImpl.invokeCommand(Address target,
ReplicableCommand command,
ResponseCollector<T> collector,
RpcOptions rpcOptions) |
<T> CompletionStage<T> |
RpcManager.invokeCommand(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
RpcOptions rpcOptions)
Invoke a command on a collection of node and pass the responses to a
ResponseCollector. |
<T> CompletionStage<T> |
RpcManagerImpl.invokeCommand(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
RpcOptions rpcOptions) |
<T> CompletionStage<T> |
RpcManager.invokeCommandOnAll(ReplicableCommand command,
ResponseCollector<T> collector,
RpcOptions rpcOptions)
Invoke a command on all the nodes in the cluster and pass the responses to a
ResponseCollector. |
<T> CompletionStage<T> |
RpcManagerImpl.invokeCommandOnAll(ReplicableCommand command,
ResponseCollector<T> collector,
RpcOptions rpcOptions) |
<T> CompletionStage<T> |
RpcManager.invokeCommands(Collection<Address> targets,
Function<Address,ReplicableCommand> commandGenerator,
ResponseCollector<T> collector,
RpcOptions rpcOptions)
Invoke different commands on a collection of nodes and pass the responses to a
ResponseCollector. |
<T> CompletionStage<T> |
RpcManagerImpl.invokeCommands(Collection<Address> targets,
Function<Address,ReplicableCommand> commandGenerator,
ResponseCollector<T> collector,
RpcOptions rpcOptions) |
<T> CompletionStage<T> |
RpcManager.invokeCommandStaggered(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
RpcOptions rpcOptions)
Invoke a command on a collection of nodes and pass the responses to a
ResponseCollector. |
<T> CompletionStage<T> |
RpcManagerImpl.invokeCommandStaggered(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
RpcOptions rpcOptions) |
default CompletableFuture<Map<Address,Response>> |
RpcManager.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options)
Deprecated.
|
CompletableFuture<Map<Address,Response>> |
RpcManagerImpl.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options) |
| Modifier and Type | Field and Description |
|---|---|
protected RpcOptions |
StateConsumerImpl.rpcOptions |
Copyright © 2022 JBoss by Red Hat. All rights reserved.