This is an automated email from the ASF dual-hosted git repository.
sk0x50 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
The following commit(s) were added to refs/heads/main by this push:
new 777d97e0989 IGNITE-26796 Improve java doc (#7195)
777d97e0989 is described below
commit 777d97e09896c2e27649a683b8ad0fb1ae7340c4
Author: Egor <[email protected]>
AuthorDate: Wed Dec 10 14:53:19 2025 +0400
IGNITE-26796 Improve java doc (#7195)
---
.../ignite/internal/replicator/ReplicaService.java | 20 ++++++++++++++++----
1 file changed, 16 insertions(+), 4 deletions(-)
diff --git
a/modules/replicator/src/main/java/org/apache/ignite/internal/replicator/ReplicaService.java
b/modules/replicator/src/main/java/org/apache/ignite/internal/replicator/ReplicaService.java
index 3a2918295d7..e6871e3ff48 100644
---
a/modules/replicator/src/main/java/org/apache/ignite/internal/replicator/ReplicaService.java
+++
b/modules/replicator/src/main/java/org/apache/ignite/internal/replicator/ReplicaService.java
@@ -127,11 +127,14 @@ public class ReplicaService {
/**
* Sends request to the replica node and provides raw response.
*
+ * <p>If the replica is not yet available, the method will automatically
wait for the replica to become ready
+ * before retrying the request. The wait is bounded by the RPC timeout
configured in {@code ReplicationConfiguration}.
+ *
* @param targetNodeConsistentId A consistent id of the replica node.
* @param req Replica request.
* @return Response future with either evaluation result or completed
exceptionally.
* @see NodeStoppingException If either supplier or demander node is
stopping.
- * @see ReplicaUnavailableException If replica with given replication
group id doesn't exist or not started yet.
+ * @see AwaitReplicaTimeoutException If the replica does not become ready
within the RPC timeout period.
* @see ReplicationTimeoutException If the response could not be received
due to a timeout.
*/
private CompletableFuture<ReplicaResponse> sendToReplicaRaw(String
targetNodeConsistentId, ReplicaRequest req) {
@@ -269,11 +272,14 @@ public class ReplicaService {
/**
* Sends a request to the given replica {@code node} and returns a future
that will be completed with a result of request processing.
*
+ * <p>If the replica is not yet available, the method will automatically
wait for the replica to become ready
+ * before retrying the request. The wait is bounded by the RPC timeout
configured in {@code ReplicationConfiguration}.
+ *
* @param node Replica node.
* @param request Request.
* @return Response future with either evaluation result or completed
exceptionally.
* @see NodeStoppingException If either supplier or demander node is
stopping.
- * @see ReplicaUnavailableException If replica with given replication
group id doesn't exist or not started yet.
+ * @see AwaitReplicaTimeoutException If the replica does not become ready
within the RPC timeout period.
* @see ReplicationTimeoutException If the response could not be received
due to a timeout.
*/
public <R> CompletableFuture<R> invoke(InternalClusterNode node,
ReplicaRequest request) {
@@ -283,11 +289,14 @@ public class ReplicaService {
/**
* Sends a request to the given replica {@code node} and returns a future
that will be completed with a result of request processing.
*
+ * <p>If the replica is not yet available, the method will automatically
wait for the replica to become ready
+ * before retrying the request. The wait is bounded by the RPC timeout
configured in {@code ReplicationConfiguration}.
+ *
* @param replicaConsistentId A consistent id of the replica node.
* @param request Request.
* @return Response future with either evaluation result or completed
exceptionally.
* @see NodeStoppingException If either supplier or demander node is
stopping.
- * @see ReplicaUnavailableException If replica with given replication
group id doesn't exist or not started yet.
+ * @see AwaitReplicaTimeoutException If the replica does not become ready
within the RPC timeout period.
* @see ReplicationTimeoutException If the response could not be received
due to a timeout.
*/
public <R> CompletableFuture<R> invoke(String replicaConsistentId,
ReplicaRequest request) {
@@ -297,12 +306,15 @@ public class ReplicaService {
/**
* Sends a request to the given replica {@code node} and returns a future
that will be completed with a result of request processing.
*
+ * <p>If the replica is not yet available, the method will automatically
wait for the replica to become ready
+ * before retrying the request. The wait is bounded by the RPC timeout
configured in {@code ReplicationConfiguration}.
+ *
* @param node Replica node.
* @param request Request.
* @param storageId Storage id.
* @return Response future with either evaluation result or completed
exceptionally.
* @see NodeStoppingException If either supplier or demander node is
stopping.
- * @see ReplicaUnavailableException If replica with given replication
group id doesn't exist or not started yet.
+ * @see AwaitReplicaTimeoutException If the replica does not become ready
within the RPC timeout period.
* @see ReplicationTimeoutException If the response could not be received
due to a timeout.
*/
public <R> CompletableFuture<R> invoke(InternalClusterNode node,
ReplicaRequest request, String storageId) {
