Integrate retention leases to recovery from remote

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

@@ -115,7 +115,7 @@ public void onFailure(final Exception e) {
         }
 
         @Override
-        protected Response shardOperation(final T request, final ShardId shardId) throws IOException {
+        protected Response shardOperation(final T request, final ShardId shardId) {
             throw new UnsupportedOperationException();
         }
 
@@ -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,40 @@
+/*
+ * 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 org.elasticsearch.index.Index;
+
+import java.util.Locale;
+
+public class CcrRetentionLeases {
+
+    /**
+     * The retention lease ID used by followers.
+     *
+     * @param localClusterName   the local cluster name
+     * @param followerIndex      the follower index
+     * @param remoteClusterAlias the remote cluster alias
+     * @param leaderIndex        the leader index
+     * @return the retention lease ID
+     */
+    public static String retentionLeaseId(
+            final String localClusterName,
+            final Index followerIndex,
+            final String remoteClusterAlias,
+            final Index leaderIndex) {
+        return String.format(
+                Locale.ROOT,
+                "%s/%s/%s-following-%s/%s/%s",
+                localClusterName,
+                followerIndex.getName(),
+                followerIndex.getUUID(),
+                remoteClusterAlias,
+                leaderIndex.getName(),
+                leaderIndex.getUUID());
+    }
+
+}