Remove default getShardSnapshotsInProgress

Author: nicktindall

server/src/main/java/org/elasticsearch/repositories/FilterRepository.java

@@ -26,6 +26,7 @@
 import org.elasticsearch.indices.recovery.RecoveryState;
 import org.elasticsearch.snapshots.SnapshotId;
 import org.elasticsearch.snapshots.SnapshotInfo;
+import org.elasticsearch.telemetry.metric.LongWithAttributes;
 
 import java.io.IOException;
 import java.util.Collection;
@@ -175,6 +176,11 @@ public void awaitIdle() {
         in.awaitIdle();
     }
 
+    @Override
+    public LongWithAttributes getShardSnapshotsInProgress() {
+        return in.getShardSnapshotsInProgress();
+    }
+
     @Override
     public Lifecycle.State lifecycleState() {
         return in.lifecycleState();

server/src/main/java/org/elasticsearch/repositories/InvalidRepository.java

@@ -25,6 +25,7 @@
 import org.elasticsearch.indices.recovery.RecoveryState;
 import org.elasticsearch.snapshots.SnapshotId;
 import org.elasticsearch.snapshots.SnapshotInfo;
+import org.elasticsearch.telemetry.metric.LongWithAttributes;
 
 import java.io.IOException;
 import java.util.Collection;
@@ -180,6 +181,11 @@ public void awaitIdle() {
 
     }
 
+    @Override
+    public LongWithAttributes getShardSnapshotsInProgress() {
+        return null;
+    }
+
     @Override
     protected void doStart() {
 

server/src/main/java/org/elasticsearch/repositories/Repository.java

@@ -361,9 +361,7 @@ static boolean assertSnapshotMetaThread() {
      * @return The current number of shard snapshots in progress metric value, or null if this repository doesn't track that
      */
     @Nullable
-    default LongWithAttributes getShardSnapshotsInProgress() {
-        return null;
-    }
+    LongWithAttributes getShardSnapshotsInProgress();
 
     default RepositoriesStats.SnapshotStats getSnapshotStats() {
         return new RepositoriesStats.SnapshotStats(getRestoreThrottleTimeInNanos(), getSnapshotThrottleTimeInNanos());

server/src/main/java/org/elasticsearch/repositories/UnknownTypeRepository.java

@@ -25,6 +25,7 @@
 import org.elasticsearch.indices.recovery.RecoveryState;
 import org.elasticsearch.snapshots.SnapshotId;
 import org.elasticsearch.snapshots.SnapshotInfo;
+import org.elasticsearch.telemetry.metric.LongWithAttributes;
 
 import java.io.IOException;
 import java.util.Collection;
@@ -178,6 +179,11 @@ public void awaitIdle() {
 
     }
 
+    @Override
+    public LongWithAttributes getShardSnapshotsInProgress() {
+        return null;
+    }
+
     @Override
     protected void doStart() {
 

server/src/test/java/org/elasticsearch/repositories/RepositoriesServiceTests.java

@@ -53,6 +53,7 @@
 import org.elasticsearch.repositories.blobstore.MeteredBlobStoreRepository;
 import org.elasticsearch.snapshots.SnapshotId;
 import org.elasticsearch.snapshots.SnapshotInfo;
+import org.elasticsearch.telemetry.metric.LongWithAttributes;
 import org.elasticsearch.test.ClusterServiceUtils;
 import org.elasticsearch.test.ESTestCase;
 import org.elasticsearch.threadpool.TestThreadPool;
@@ -772,6 +773,11 @@ public void cloneShardSnapshot(
         @Override
         public void awaitIdle() {}
 
+        @Override
+        public LongWithAttributes getShardSnapshotsInProgress() {
+            return null;
+        }
+
         @Override
         public Lifecycle.State lifecycleState() {
             return null;

test/framework/src/main/java/org/elasticsearch/index/shard/RestoreOnlyRepository.java

@@ -31,6 +31,7 @@
 import org.elasticsearch.repositories.SnapshotShardContext;
 import org.elasticsearch.snapshots.SnapshotId;
 import org.elasticsearch.snapshots.SnapshotInfo;
+import org.elasticsearch.telemetry.metric.LongWithAttributes;
 
 import java.util.Collection;
 import java.util.Collections;
@@ -175,4 +176,9 @@ public void cloneShardSnapshot(
 
         throw new UnsupportedOperationException("Unsupported for restore-only repository");
     }
+
+    @Override
+    public LongWithAttributes getShardSnapshotsInProgress() {
+        return null;
+    }
 }

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

@@ -86,6 +86,7 @@
 import org.elasticsearch.snapshots.SnapshotId;
 import org.elasticsearch.snapshots.SnapshotInfo;
 import org.elasticsearch.snapshots.SnapshotState;
+import org.elasticsearch.telemetry.metric.LongWithAttributes;
 import org.elasticsearch.threadpool.Scheduler;
 import org.elasticsearch.threadpool.ThreadPool;
 import org.elasticsearch.transport.RemoteClusterService;
@@ -618,6 +619,11 @@ public void cloneShardSnapshot(
     @Override
     public void awaitIdle() {}
 
+    @Override
+    public LongWithAttributes getShardSnapshotsInProgress() {
+        return null;
+    }
+
     private void updateMappings(
         RemoteClusterClient leaderClient,
         Index leaderIndex,