| Package | Description |
|---|---|
| org.infinispan.interceptors.distribution |
Interceptors dealing with command replication in distributed/replicated mode.
|
| org.infinispan.remoting.responses |
Abstractions of the different response types allowed during RPC.
|
| 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.util |
General utilities that are not specific to Infinispan, including string parsing helpers, reflection tools and
collections and containers designed to supplement the JDK-provided containers.
|
| Modifier and Type | Method and Description |
|---|---|
default ValidResponse |
BiasedCollector.addResponse(Address sender,
Response response) |
default ValidResponse |
BiasedCollector.finish() |
| Modifier and Type | Method and Description |
|---|---|
protected CompletionStage<ValidResponse> |
BiasedScatteredDistributionInterceptor.manyWriteOnRemotePrimary(Address target,
WriteCommand command,
CommandAckCollector.MultiTargetCollector multiTargetCollector) |
protected CompletionStage<ValidResponse> |
ScatteredDistributionInterceptor.manyWriteOnRemotePrimary(Address target,
WriteCommand command,
CommandAckCollector.MultiTargetCollector multiTargetCollector) |
protected CompletionStage<ValidResponse> |
BiasedScatteredDistributionInterceptor.singleWriteOnRemotePrimary(Address target,
DataWriteCommand command) |
protected CompletionStage<ValidResponse> |
ScatteredDistributionInterceptor.singleWriteOnRemotePrimary(Address target,
DataWriteCommand command)
This method is called by a non-owner sending write request to the primary owner
|
| Modifier and Type | Class and Description |
|---|---|
class |
BiasRevocationResponse |
class |
PrepareResponse
A
ValidResponse used by Optimistic Transactions. |
class |
SuccessfulResponse<T>
A successful response
|
class |
UnsuccessfulResponse
An unsuccessful response
|
class |
UnsureResponse
An unsure response - used with Dist - essentially asks the caller to check the next response from the next node since
the sender is in a state of flux (probably in the middle of rebalancing)
|
| Modifier and Type | Method and Description |
|---|---|
protected abstract T |
ValidResponseCollector.addValidResponse(Address sender,
ValidResponse response)
Process a valid response from a target.
|
protected abstract T |
ValidSingleResponseCollector.withValidResponse(Address sender,
ValidResponse response) |
| Modifier and Type | Method and Description |
|---|---|
protected ValidResponse |
SingleResponseCollector.targetNotFound(Address sender) |
protected ValidResponse |
SingleResponseCollector.withValidResponse(Address sender,
ValidResponse response) |
| Modifier and Type | Method and Description |
|---|---|
protected Void |
VoidResponseCollector.addValidResponse(Address sender,
ValidResponse response) |
protected Map<Address,Response> |
FilterMapResponseCollector.addValidResponse(Address sender,
ValidResponse response) |
protected Map<Address,Response> |
MapResponseCollector.addValidResponse(Address sender,
ValidResponse response) |
protected ValidResponse |
SingleResponseCollector.withValidResponse(Address sender,
ValidResponse response) |
protected Map<Address,Response> |
SingletonMapResponseCollector.withValidResponse(Address sender,
ValidResponse response) |
| Constructor and Description |
|---|
JGroupsBackupResponse(Map<XSiteBackup,CompletableFuture<ValidResponse>> backupCalls,
TimeService timeService) |
| Modifier and Type | Method and Description |
|---|---|
static Map<Object,Object> |
TriangleFunctionsUtil.mergeHashMap(ValidResponse response,
Map<Object,Object> resultMap) |
static List<Object> |
TriangleFunctionsUtil.mergeList(ValidResponse response,
List<Object> resultList) |
static Void |
TriangleFunctionsUtil.voidMerge(ValidResponse ignored1,
Void ignored2) |
Copyright © 2022 JBoss by Red Hat. All rights reserved.