Package | Description |
---|---|
org.infinispan.commands.remote |
Meta-commands that wrap other commands for remote execution.
|
org.infinispan.interceptors.distribution |
Interceptors dealing with command replication in distributed/replicated mode.
|
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.impl | |
org.infinispan.remoting.transport.jgroups |
A transport implementation based on JGroups.
|
org.infinispan.topology |
Modifier and Type | Method and Description |
---|---|
static ResponseCollector<Collection<GlobalTransaction>> |
CheckTransactionRpcCommand.responseCollector() |
Modifier and Type | Interface and Description |
---|---|
interface |
BiasedCollector |
Modifier and Type | Class and Description |
---|---|
class |
RemoteGetSingleKeyCollector
Return the first successful response for a staggered remote get, used in dist mode.
|
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) |
Modifier and Type | Class and Description |
---|---|
class |
ValidResponseCollector<T>
Base class for response collectors, splitting responses into valid responses, exception responses, and target missing.
|
class |
ValidSingleResponseCollector<T> |
Modifier and Type | Field and Description |
---|---|
protected ResponseCollector<T> |
AbstractRequest.responseCollector |
Modifier and Type | Method and Description |
---|---|
<T> CompletionStage<T> |
AbstractDelegatingTransport.invokeCommand(Address target,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
default <T> CompletionStage<T> |
Transport.invokeCommand(Address target,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit)
Invoke a command on a single node and pass the response to a
ResponseCollector . |
<T> CompletionStage<T> |
AbstractDelegatingTransport.invokeCommand(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
default <T> CompletionStage<T> |
Transport.invokeCommand(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit)
Invoke a command on a collection of node and pass the responses to a
ResponseCollector . |
default <T> CompletionStage<T> |
Transport.invokeCommandOnAll(Collection<Address> requiredTargets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit)
Invoke a command on all the nodes in the cluster and pass the responses to a
ResponseCollector . |
<T> CompletionStage<T> |
AbstractDelegatingTransport.invokeCommandOnAll(ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
default <T> CompletionStage<T> |
Transport.invokeCommandOnAll(ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit)
Invoke a command on all the nodes in the cluster and pass the responses to a
ResponseCollector . |
<T> CompletionStage<T> |
AbstractDelegatingTransport.invokeCommands(Collection<Address> targets,
Function<Address,ReplicableCommand> commandGenerator,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit timeUnit) |
default <T> CompletionStage<T> |
Transport.invokeCommands(Collection<Address> targets,
Function<Address,ReplicableCommand> commandGenerator,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit timeUnit)
Invoke different commands on a collection of nodes and pass the responses to a
ResponseCollector . |
default <T> CompletionStage<T> |
Transport.invokeCommands(Collection<Address> targets,
Function<Address,ReplicableCommand> commandGenerator,
ResponseCollector<T> responseCollector,
long timeout,
DeliverOrder deliverOrder)
Deprecated.
Introduced in 9.1, but replaced in 9.2 with
Transport.invokeCommands(Collection, Function, ResponseCollector, DeliverOrder, long, TimeUnit) . |
<T> CompletionStage<T> |
AbstractDelegatingTransport.invokeCommandStaggered(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
default <T> CompletionStage<T> |
Transport.invokeCommandStaggered(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit)
Invoke a command on a collection of nodes and pass the responses to a
ResponseCollector . |
Constructor and Description |
---|
AbstractRequest(long requestId,
ResponseCollector<T> responseCollector,
RequestRepository repository) |
Modifier and Type | Class and Description |
---|---|
class |
FilterMapResponseCollector
|
class |
MapResponseCollector
|
class |
PassthroughMapResponseCollector
Receive responses from multiple nodes, without checking that the responses are valid.
|
class |
PassthroughSingleResponseCollector
RPC to a single node, without any validity checks.
|
class |
SingleResponseCollector
Response collector for a single response.
|
class |
SingletonMapResponseCollector
|
class |
VoidResponseCollector
Response collector that discards successful responses and returns
null . |
Constructor and Description |
---|
MultiTargetRequest(ResponseCollector<T> responseCollector,
long requestId,
RequestRepository repository,
Collection<Address> targets,
Address excluded) |
SingleTargetRequest(ResponseCollector<T> wrapper,
long requestId,
RequestRepository repository,
Address target) |
Modifier and Type | Method and Description |
---|---|
<T> CompletionStage<T> |
JGroupsTransport.invokeCommand(Address target,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
<T> CompletionStage<T> |
JGroupsTransport.invokeCommand(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
<T> CompletionStage<T> |
JGroupsTransport.invokeCommandOnAll(Collection<Address> requiredTargets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
<T> CompletionStage<T> |
JGroupsTransport.invokeCommandOnAll(ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
<T> CompletionStage<T> |
JGroupsTransport.invokeCommands(Collection<Address> targets,
Function<Address,ReplicableCommand> commandGenerator,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit timeUnit) |
<T> CompletionStage<T> |
JGroupsTransport.invokeCommandStaggered(Collection<Address> targets,
ReplicableCommand command,
ResponseCollector<T> collector,
DeliverOrder deliverOrder,
long timeout,
TimeUnit unit) |
Modifier and Type | Method and Description |
---|---|
<T> CompletionStage<T> |
TopologyManagementHelper.executeOnClusterSync(Transport transport,
ReplicableCommand command,
int timeout,
ResponseCollector<T> responseCollector) |
Copyright © 2021 JBoss by Red Hat. All rights reserved.