Integrate retention leases to recovery from remote

server/src/main/java/org/elasticsearch/index/seqno/RetentionLeaseActions.java

@@ -136,10 +136,10 @@ protected boolean resolveIndex(final T request) {
     public static class Add extends Action<Response> {
 
         public static final Add INSTANCE = new Add();
-        public static final String NAME = "indices:admin/seq_no/add_retention_lease";
+        public static final String ACTION_NAME = "indices:admin/seq_no/add_retention_lease";
 
         private Add() {
-            super(NAME);
+            super(ACTION_NAME);
         }
 
         public static class TransportAction extends TransportRetentionLeaseAction<AddRequest> {
@@ -153,7 +153,7 @@ public TransportAction(
                     final IndexNameExpressionResolver indexNameExpressionResolver,
                     final IndicesService indicesService) {
                 super(
-                        NAME,
+                        ACTION_NAME,
                         threadPool,
                         clusterService,
                         transportService,
@@ -186,10 +186,10 @@ public Response newResponse() {
     public static class Renew extends Action<Response> {
 
         public static final Renew INSTANCE = new Renew();
-        public static final String NAME = "indices:admin/seq_no/renew_retention_lease";
+        public static final String ACTION_NAME = "indices:admin/seq_no/renew_retention_lease";
 
         private Renew() {
-            super(NAME);
+            super(ACTION_NAME);
         }
 
         public static class TransportAction extends TransportRetentionLeaseAction<RenewRequest> {
@@ -203,7 +203,7 @@ public TransportAction(
                     final IndexNameExpressionResolver indexNameExpressionResolver,
                     final IndicesService indicesService) {
                 super(
-                        NAME,
+                        ACTION_NAME,
                         threadPool,
                         clusterService,
                         transportService,
@@ -232,10 +232,10 @@ public Response newResponse() {
     public static class Remove extends Action<Response> {
 
         public static final Remove INSTANCE = new Remove();
-        public static final String NAME = "indices:admin/seq_no/remove_retention_lease";
+        public static final String ACTION_NAME = "indices:admin/seq_no/remove_retention_lease";
 
         private Remove() {
-            super(NAME);
+            super(ACTION_NAME);
         }
 
         public static class TransportAction extends TransportRetentionLeaseAction<RemoveRequest> {
@@ -249,7 +249,7 @@ public TransportAction(
                     final IndexNameExpressionResolver indexNameExpressionResolver,
                     final IndicesService indicesService) {
                 super(
-                        NAME,
+                        ACTION_NAME,
                         threadPool,
                         clusterService,
                         transportService,

server/src/main/java/org/elasticsearch/index/seqno/RetentionLeaseAlreadyExistsException.java

@@ -27,7 +27,7 @@
 
 public class RetentionLeaseAlreadyExistsException extends ResourceAlreadyExistsException {
 
-    RetentionLeaseAlreadyExistsException(final String id) {
+    public RetentionLeaseAlreadyExistsException(final String id) {
         super("retention lease with ID [" + Objects.requireNonNull(id) + "] already exists");
     }
 

server/src/main/java/org/elasticsearch/index/seqno/RetentionLeaseNotFoundException.java

@@ -27,7 +27,7 @@
 
 public class RetentionLeaseNotFoundException extends ResourceNotFoundException {
 
-    RetentionLeaseNotFoundException(final String id) {
+    public RetentionLeaseNotFoundException(final String id) {
         super("retention lease with ID [" + Objects.requireNonNull(id) + "] not found");
     }
 

x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/CcrRetentionLeases.java

@@ -0,0 +1,38 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+
+package org.elasticsearch.xpack.ccr;
+
+import java.util.Locale;
+
+public class CcrRetentionLeases {
+
+    /**
+     * The retention lease ID used by followers.
+     *
+     * @param followerUUID the follower index UUID
+     * @param leaderUUID   the leader index UUID
+     * @return the retention lease ID
+     */
+    public static String retentionLeaseId(
+            final String localClusterName,
+            final String remoteClusterName,
+            final String followerIndexName,
+            final String followerUUID,
+            final String leaderIndexName,
+            final String leaderUUID) {
+        return String.format(
+                Locale.ROOT,
+                "%s/%s/%s-following-%s/%s/%s",
+                localClusterName,
+                followerIndexName,
+                followerUUID,
+                remoteClusterName,
+                leaderIndexName,
+                leaderUUID);
+    }
+
+}