Skip to content

Commit e2665d1

Browse files
committed
URLRepository
1 parent 3aa7ca6 commit e2665d1

File tree

3 files changed

+8
-13
lines changed

3 files changed

+8
-13
lines changed

modules/repository-url/src/main/java/org/elasticsearch/plugin/repository/url/URLRepositoryPlugin.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,8 @@ public Map<String, Repository.Factory> getRepositories(
6363
clusterService,
6464
bigArrays,
6565
recoverySettings,
66-
httpClientFactory.updateAndGet(factory -> factory == null ? new URLHttpClient.Factory() : factory)
66+
httpClientFactory.updateAndGet(factory -> factory == null ? new URLHttpClient.Factory() : factory),
67+
snapshotMetrics
6768
)
6869
);
6970
}

modules/repository-url/src/main/java/org/elasticsearch/repositories/url/URLRepository.java

Lines changed: 3 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -101,18 +101,10 @@ public URLRepository(
101101
ClusterService clusterService,
102102
BigArrays bigArrays,
103103
RecoverySettings recoverySettings,
104-
URLHttpClient.Factory httpClientFactory
104+
URLHttpClient.Factory httpClientFactory,
105+
SnapshotMetrics snapshotMetrics
105106
) {
106-
super(
107-
projectId,
108-
metadata,
109-
namedXContentRegistry,
110-
clusterService,
111-
bigArrays,
112-
recoverySettings,
113-
BlobPath.EMPTY,
114-
SnapshotMetrics.NOOP
115-
);
107+
super(projectId, metadata, namedXContentRegistry, clusterService, bigArrays, recoverySettings, BlobPath.EMPTY, snapshotMetrics);
116108

117109
if (URL_SETTING.exists(metadata.settings()) == false && REPOSITORIES_URL_SETTING.exists(environment.settings()) == false) {
118110
throw new RepositoryException(metadata.name(), "missing url");

modules/repository-url/src/test/java/org/elasticsearch/repositories/url/URLRepositoryTests.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
import org.elasticsearch.env.TestEnvironment;
2020
import org.elasticsearch.indices.recovery.RecoverySettings;
2121
import org.elasticsearch.repositories.RepositoryException;
22+
import org.elasticsearch.repositories.SnapshotMetrics;
2223
import org.elasticsearch.repositories.blobstore.BlobStoreTestUtil;
2324
import org.elasticsearch.test.ESTestCase;
2425
import org.elasticsearch.xcontent.NamedXContentRegistry;
@@ -45,7 +46,8 @@ private URLRepository createRepository(Settings baseSettings, RepositoryMetadata
4546
BlobStoreTestUtil.mockClusterService(),
4647
MockBigArrays.NON_RECYCLING_INSTANCE,
4748
new RecoverySettings(baseSettings, new ClusterSettings(baseSettings, ClusterSettings.BUILT_IN_CLUSTER_SETTINGS)),
48-
mock(URLHttpClient.Factory.class)
49+
mock(URLHttpClient.Factory.class),
50+
SnapshotMetrics.NOOP
4951
);
5052
assertThat(repository.getProjectId(), equalTo(projectId));
5153
return repository;

0 commit comments

Comments
 (0)