Skip to content

Commit b5d8495

Browse files
martijnvgmartijnvg
authored
[CCR] Add auto follow pattern APIs to transport client. (#33629)
1 parent 20c6c9c commit b5d8495

16 files changed

+68
-37
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -40,8 +40,8 @@
4040
import org.elasticsearch.threadpool.ThreadPool;
4141
import org.elasticsearch.watcher.ResourceWatcherService;
4242
import org.elasticsearch.xpack.ccr.action.AutoFollowCoordinator;
43-
import org.elasticsearch.xpack.ccr.action.DeleteAutoFollowPatternAction;
44-
import org.elasticsearch.xpack.ccr.action.PutAutoFollowPatternAction;
43+
import org.elasticsearch.xpack.core.ccr.action.DeleteAutoFollowPatternAction;
44+
import org.elasticsearch.xpack.core.ccr.action.PutAutoFollowPatternAction;
4545
import org.elasticsearch.xpack.ccr.action.ShardChangesAction;
4646
import org.elasticsearch.xpack.ccr.action.ShardFollowTask;
4747
import org.elasticsearch.xpack.ccr.action.ShardFollowTasksExecutor;

‎x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/AutoFollowCoordinator.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -218,7 +218,7 @@ private void handleClusterAlias(String clusterAlias, AutoFollowPattern autoFollo
218218
new FollowIndexAction.Request(leaderIndexNameWithClusterAliasPrefix, followIndexName,
219219
autoFollowPattern.getMaxBatchOperationCount(), autoFollowPattern.getMaxConcurrentReadBatches(),
220220
autoFollowPattern.getMaxOperationSizeInBytes(), autoFollowPattern.getMaxConcurrentWriteBatches(),
221-
autoFollowPattern.getMaxWriteBufferSize(), autoFollowPattern.getRetryTimeout(),
221+
autoFollowPattern.getMaxWriteBufferSize(), autoFollowPattern.getMaxRetryDelay(),
222222
autoFollowPattern.getIdleShardRetryDelay());
223223

224224
// Execute if the create and follow api call succeeds:

‎x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/TransportDeleteAutoFollowPatternAction.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323
import org.elasticsearch.transport.TransportService;
2424
import org.elasticsearch.xpack.core.ccr.AutoFollowMetadata;
2525
import org.elasticsearch.xpack.core.ccr.AutoFollowMetadata.AutoFollowPattern;
26+
import org.elasticsearch.xpack.core.ccr.action.DeleteAutoFollowPatternAction;
2627

2728
import java.util.HashMap;
2829
import java.util.List;

‎x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/TransportPutAutoFollowPatternAction.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@
2727
import org.elasticsearch.xpack.ccr.CcrLicenseChecker;
2828
import org.elasticsearch.xpack.core.ccr.AutoFollowMetadata;
2929
import org.elasticsearch.xpack.core.ccr.AutoFollowMetadata.AutoFollowPattern;
30+
import org.elasticsearch.xpack.core.ccr.action.PutAutoFollowPatternAction;
3031

3132
import java.util.ArrayList;
3233
import java.util.HashMap;

‎x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/rest/RestDeleteAutoFollowPatternAction.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,11 +11,11 @@
1111
import org.elasticsearch.rest.RestController;
1212
import org.elasticsearch.rest.RestRequest;
1313
import org.elasticsearch.rest.action.RestToXContentListener;
14-
import org.elasticsearch.xpack.ccr.action.DeleteAutoFollowPatternAction.Request;
14+
import org.elasticsearch.xpack.core.ccr.action.DeleteAutoFollowPatternAction.Request;
1515

1616
import java.io.IOException;
1717

18-
import static org.elasticsearch.xpack.ccr.action.DeleteAutoFollowPatternAction.INSTANCE;
18+
import static org.elasticsearch.xpack.core.ccr.action.DeleteAutoFollowPatternAction.INSTANCE;
1919

2020
public class RestDeleteAutoFollowPatternAction extends BaseRestHandler {
2121

‎x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/rest/RestPutAutoFollowPatternAction.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -12,11 +12,11 @@
1212
import org.elasticsearch.rest.RestController;
1313
import org.elasticsearch.rest.RestRequest;
1414
import org.elasticsearch.rest.action.RestToXContentListener;
15-
import org.elasticsearch.xpack.ccr.action.PutAutoFollowPatternAction.Request;
15+
import org.elasticsearch.xpack.core.ccr.action.PutAutoFollowPatternAction.Request;
1616

1717
import java.io.IOException;
1818

19-
import static org.elasticsearch.xpack.ccr.action.PutAutoFollowPatternAction.INSTANCE;
19+
import static org.elasticsearch.xpack.core.ccr.action.PutAutoFollowPatternAction.INSTANCE;
2020

2121
public class RestPutAutoFollowPatternAction extends BaseRestHandler {
2222

‎x-pack/plugin/ccr/src/test/java/org/elasticsearch/xpack/ccr/CcrLicenseIT.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,9 +25,9 @@
2525
import org.elasticsearch.xpack.core.ccr.action.CcrStatsAction;
2626
import org.elasticsearch.xpack.core.ccr.action.CreateAndFollowIndexAction;
2727
import org.elasticsearch.xpack.core.ccr.action.FollowIndexAction;
28-
import org.elasticsearch.xpack.ccr.action.PutAutoFollowPatternAction;
2928
import org.elasticsearch.xpack.core.ccr.AutoFollowMetadata;
3029
import org.elasticsearch.xpack.core.ccr.AutoFollowMetadata.AutoFollowPattern;
30+
import org.elasticsearch.xpack.core.ccr.action.PutAutoFollowPatternAction;
3131

3232
import java.util.Collection;
3333
import java.util.Collections;

‎x-pack/plugin/ccr/src/test/java/org/elasticsearch/xpack/ccr/action/AutoFollowTests.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,8 @@
1515
import org.elasticsearch.plugins.Plugin;
1616
import org.elasticsearch.test.ESSingleNodeTestCase;
1717
import org.elasticsearch.xpack.ccr.LocalStateCcr;
18+
import org.elasticsearch.xpack.core.ccr.action.DeleteAutoFollowPatternAction;
19+
import org.elasticsearch.xpack.core.ccr.action.PutAutoFollowPatternAction;
1820

1921
import java.util.Arrays;
2022
import java.util.Collection;

‎x-pack/plugin/ccr/src/test/java/org/elasticsearch/xpack/ccr/action/TransportDeleteAutoFollowPatternActionTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010
import org.elasticsearch.cluster.ClusterState;
1111
import org.elasticsearch.cluster.metadata.MetaData;
1212
import org.elasticsearch.test.ESTestCase;
13-
import org.elasticsearch.xpack.ccr.action.DeleteAutoFollowPatternAction.Request;
13+
import org.elasticsearch.xpack.core.ccr.action.DeleteAutoFollowPatternAction.Request;
1414
import org.elasticsearch.xpack.core.ccr.AutoFollowMetadata;
1515

1616
import java.util.ArrayList;

‎x-pack/plugin/ccr/src/test/java/org/elasticsearch/xpack/ccr/action/TransportPutAutoFollowPatternActionTests.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@
1212
import org.elasticsearch.cluster.metadata.MetaData;
1313
import org.elasticsearch.test.ESTestCase;
1414
import org.elasticsearch.xpack.core.ccr.AutoFollowMetadata;
15+
import org.elasticsearch.xpack.core.ccr.action.PutAutoFollowPatternAction;
1516

1617
import java.util.ArrayList;
1718
import java.util.Arrays;

‎x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ccr/AutoFollowMetadata.java

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -169,7 +169,7 @@ public static class AutoFollowPattern implements Writeable, ToXContentObject {
169169
public static final ParseField MAX_BATCH_SIZE_IN_BYTES = new ParseField("max_batch_size_in_bytes");
170170
public static final ParseField MAX_CONCURRENT_WRITE_BATCHES = new ParseField("max_concurrent_write_batches");
171171
public static final ParseField MAX_WRITE_BUFFER_SIZE = new ParseField("max_write_buffer_size");
172-
public static final ParseField RETRY_TIMEOUT = new ParseField("retry_timeout");
172+
public static final ParseField MAX_RETRY_DELAY = new ParseField("retry_timeout");
173173
public static final ParseField IDLE_SHARD_RETRY_DELAY = new ParseField("idle_shard_retry_delay");
174174

175175
@SuppressWarnings("unchecked")
@@ -187,8 +187,8 @@ public static class AutoFollowPattern implements Writeable, ToXContentObject {
187187
PARSER.declareInt(ConstructingObjectParser.optionalConstructorArg(), MAX_CONCURRENT_WRITE_BATCHES);
188188
PARSER.declareInt(ConstructingObjectParser.optionalConstructorArg(), MAX_WRITE_BUFFER_SIZE);
189189
PARSER.declareField(ConstructingObjectParser.optionalConstructorArg(),
190-
(p, c) -> TimeValue.parseTimeValue(p.text(), RETRY_TIMEOUT.getPreferredName()),
191-
RETRY_TIMEOUT, ObjectParser.ValueType.STRING);
190+
(p, c) -> TimeValue.parseTimeValue(p.text(), MAX_RETRY_DELAY.getPreferredName()),
191+
MAX_RETRY_DELAY, ObjectParser.ValueType.STRING);
192192
PARSER.declareField(ConstructingObjectParser.optionalConstructorArg(),
193193
(p, c) -> TimeValue.parseTimeValue(p.text(), IDLE_SHARD_RETRY_DELAY.getPreferredName()),
194194
IDLE_SHARD_RETRY_DELAY, ObjectParser.ValueType.STRING);
@@ -201,20 +201,20 @@ public static class AutoFollowPattern implements Writeable, ToXContentObject {
201201
private final Long maxOperationSizeInBytes;
202202
private final Integer maxConcurrentWriteBatches;
203203
private final Integer maxWriteBufferSize;
204-
private final TimeValue retryTimeout;
204+
private final TimeValue maxRetryDelay;
205205
private final TimeValue idleShardRetryDelay;
206206

207207
public AutoFollowPattern(List<String> leaderIndexPatterns, String followIndexPattern, Integer maxBatchOperationCount,
208208
Integer maxConcurrentReadBatches, Long maxOperationSizeInBytes, Integer maxConcurrentWriteBatches,
209-
Integer maxWriteBufferSize, TimeValue retryTimeout, TimeValue idleShardRetryDelay) {
209+
Integer maxWriteBufferSize, TimeValue maxRetryDelay, TimeValue idleShardRetryDelay) {
210210
this.leaderIndexPatterns = leaderIndexPatterns;
211211
this.followIndexPattern = followIndexPattern;
212212
this.maxBatchOperationCount = maxBatchOperationCount;
213213
this.maxConcurrentReadBatches = maxConcurrentReadBatches;
214214
this.maxOperationSizeInBytes = maxOperationSizeInBytes;
215215
this.maxConcurrentWriteBatches = maxConcurrentWriteBatches;
216216
this.maxWriteBufferSize = maxWriteBufferSize;
217-
this.retryTimeout = retryTimeout;
217+
this.maxRetryDelay = maxRetryDelay;
218218
this.idleShardRetryDelay = idleShardRetryDelay;
219219
}
220220

@@ -226,7 +226,7 @@ public AutoFollowPattern(List<String> leaderIndexPatterns, String followIndexPat
226226
maxOperationSizeInBytes = in.readOptionalLong();
227227
maxConcurrentWriteBatches = in.readOptionalVInt();
228228
maxWriteBufferSize = in.readOptionalVInt();
229-
retryTimeout = in.readOptionalTimeValue();
229+
maxRetryDelay = in.readOptionalTimeValue();
230230
idleShardRetryDelay = in.readOptionalTimeValue();
231231
}
232232

@@ -266,8 +266,8 @@ public Integer getMaxWriteBufferSize() {
266266
return maxWriteBufferSize;
267267
}
268268

269-
public TimeValue getRetryTimeout() {
270-
return retryTimeout;
269+
public TimeValue getMaxRetryDelay() {
270+
return maxRetryDelay;
271271
}
272272

273273
public TimeValue getIdleShardRetryDelay() {
@@ -283,7 +283,7 @@ public void writeTo(StreamOutput out) throws IOException {
283283
out.writeOptionalLong(maxOperationSizeInBytes);
284284
out.writeOptionalVInt(maxConcurrentWriteBatches);
285285
out.writeOptionalVInt(maxWriteBufferSize);
286-
out.writeOptionalTimeValue(retryTimeout);
286+
out.writeOptionalTimeValue(maxRetryDelay);
287287
out.writeOptionalTimeValue(idleShardRetryDelay);
288288
}
289289

@@ -308,8 +308,8 @@ public XContentBuilder toXContent(XContentBuilder builder, Params params) throws
308308
if (maxWriteBufferSize != null){
309309
builder.field(MAX_WRITE_BUFFER_SIZE.getPreferredName(), maxWriteBufferSize);
310310
}
311-
if (retryTimeout != null) {
312-
builder.field(RETRY_TIMEOUT.getPreferredName(), retryTimeout);
311+
if (maxRetryDelay != null) {
312+
builder.field(MAX_RETRY_DELAY.getPreferredName(), maxRetryDelay);
313313
}
314314
if (idleShardRetryDelay != null) {
315315
builder.field(IDLE_SHARD_RETRY_DELAY.getPreferredName(), idleShardRetryDelay);
@@ -334,7 +334,7 @@ public boolean equals(Object o) {
334334
Objects.equals(maxOperationSizeInBytes, that.maxOperationSizeInBytes) &&
335335
Objects.equals(maxConcurrentWriteBatches, that.maxConcurrentWriteBatches) &&
336336
Objects.equals(maxWriteBufferSize, that.maxWriteBufferSize) &&
337-
Objects.equals(retryTimeout, that.retryTimeout) &&
337+
Objects.equals(maxRetryDelay, that.maxRetryDelay) &&
338338
Objects.equals(idleShardRetryDelay, that.idleShardRetryDelay);
339339
}
340340

@@ -348,7 +348,7 @@ public int hashCode() {
348348
maxOperationSizeInBytes,
349349
maxConcurrentWriteBatches,
350350
maxWriteBufferSize,
351-
retryTimeout,
351+
maxRetryDelay,
352352
idleShardRetryDelay
353353
);
354354
}

‎x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/DeleteAutoFollowPatternAction.java renamed to ‎x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ccr/action/DeleteAutoFollowPatternAction.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
* or more contributor license agreements. Licensed under the Elastic License;
44
* you may not use this file except in compliance with the Elastic License.
55
*/
6-
package org.elasticsearch.xpack.ccr.action;
6+
package org.elasticsearch.xpack.core.ccr.action;
77

88
import org.elasticsearch.action.Action;
99
import org.elasticsearch.action.ActionRequestValidationException;

‎x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/PutAutoFollowPatternAction.java renamed to ‎x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ccr/action/PutAutoFollowPatternAction.java

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
* or more contributor license agreements. Licensed under the Elastic License;
44
* you may not use this file except in compliance with the Elastic License.
55
*/
6-
package org.elasticsearch.xpack.ccr.action;
6+
package org.elasticsearch.xpack.core.ccr.action;
77

88
import org.elasticsearch.action.Action;
99
import org.elasticsearch.action.ActionRequestValidationException;
@@ -57,11 +57,11 @@ public static class Request extends AcknowledgedRequest<Request> implements ToXC
5757
PARSER.declareInt(Request::setMaxConcurrentWriteBatches, AutoFollowPattern.MAX_CONCURRENT_WRITE_BATCHES);
5858
PARSER.declareInt(Request::setMaxWriteBufferSize, AutoFollowPattern.MAX_WRITE_BUFFER_SIZE);
5959
PARSER.declareField(Request::setMaxRetryDelay,
60-
(p, c) -> TimeValue.parseTimeValue(p.text(), AutoFollowPattern.RETRY_TIMEOUT.getPreferredName()),
61-
ShardFollowTask.MAX_RETRY_DELAY, ObjectParser.ValueType.STRING);
60+
(p, c) -> TimeValue.parseTimeValue(p.text(), AutoFollowPattern.MAX_RETRY_DELAY.getPreferredName()),
61+
AutoFollowPattern.MAX_RETRY_DELAY, ObjectParser.ValueType.STRING);
6262
PARSER.declareField(Request::setIdleShardRetryDelay,
6363
(p, c) -> TimeValue.parseTimeValue(p.text(), AutoFollowPattern.IDLE_SHARD_RETRY_DELAY.getPreferredName()),
64-
ShardFollowTask.IDLE_SHARD_RETRY_DELAY, ObjectParser.ValueType.STRING);
64+
AutoFollowPattern.IDLE_SHARD_RETRY_DELAY, ObjectParser.ValueType.STRING);
6565
}
6666

6767
public static Request fromXContent(XContentParser parser, String remoteClusterAlias) throws IOException {
@@ -222,25 +222,25 @@ public XContentBuilder toXContent(XContentBuilder builder, Params params) throws
222222
builder.field(FOLLOW_INDEX_NAME_PATTERN_FIELD.getPreferredName(), followIndexNamePattern);
223223
}
224224
if (maxBatchOperationCount != null) {
225-
builder.field(ShardFollowTask.MAX_BATCH_OPERATION_COUNT.getPreferredName(), maxBatchOperationCount);
225+
builder.field(AutoFollowPattern.MAX_BATCH_OPERATION_COUNT.getPreferredName(), maxBatchOperationCount);
226226
}
227227
if (maxOperationSizeInBytes != null) {
228-
builder.field(ShardFollowTask.MAX_BATCH_SIZE_IN_BYTES.getPreferredName(), maxOperationSizeInBytes);
228+
builder.field(AutoFollowPattern.MAX_BATCH_SIZE_IN_BYTES.getPreferredName(), maxOperationSizeInBytes);
229229
}
230230
if (maxWriteBufferSize != null) {
231-
builder.field(ShardFollowTask.MAX_WRITE_BUFFER_SIZE.getPreferredName(), maxWriteBufferSize);
231+
builder.field(AutoFollowPattern.MAX_WRITE_BUFFER_SIZE.getPreferredName(), maxWriteBufferSize);
232232
}
233233
if (maxConcurrentReadBatches != null) {
234-
builder.field(ShardFollowTask.MAX_CONCURRENT_READ_BATCHES.getPreferredName(), maxConcurrentReadBatches);
234+
builder.field(AutoFollowPattern.MAX_CONCURRENT_READ_BATCHES.getPreferredName(), maxConcurrentReadBatches);
235235
}
236236
if (maxConcurrentWriteBatches != null) {
237-
builder.field(ShardFollowTask.MAX_CONCURRENT_WRITE_BATCHES.getPreferredName(), maxConcurrentWriteBatches);
237+
builder.field(AutoFollowPattern.MAX_CONCURRENT_WRITE_BATCHES.getPreferredName(), maxConcurrentWriteBatches);
238238
}
239239
if (maxRetryDelay != null) {
240-
builder.field(ShardFollowTask.MAX_RETRY_DELAY.getPreferredName(), maxRetryDelay.getStringRep());
240+
builder.field(AutoFollowPattern.MAX_RETRY_DELAY.getPreferredName(), maxRetryDelay.getStringRep());
241241
}
242242
if (idleShardRetryDelay != null) {
243-
builder.field(ShardFollowTask.IDLE_SHARD_RETRY_DELAY.getPreferredName(), idleShardRetryDelay.getStringRep());
243+
builder.field(AutoFollowPattern.IDLE_SHARD_RETRY_DELAY.getPreferredName(), idleShardRetryDelay.getStringRep());
244244
}
245245
}
246246
builder.endObject();

‎x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/ccr/client/CcrClient.java

Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,9 @@
1313
import org.elasticsearch.client.ElasticsearchClient;
1414
import org.elasticsearch.xpack.core.ccr.action.CcrStatsAction;
1515
import org.elasticsearch.xpack.core.ccr.action.CreateAndFollowIndexAction;
16+
import org.elasticsearch.xpack.core.ccr.action.DeleteAutoFollowPatternAction;
1617
import org.elasticsearch.xpack.core.ccr.action.FollowIndexAction;
18+
import org.elasticsearch.xpack.core.ccr.action.PutAutoFollowPatternAction;
1719
import org.elasticsearch.xpack.core.ccr.action.UnfollowIndexAction;
1820

1921
import java.util.Objects;
@@ -70,4 +72,28 @@ public ActionFuture<AcknowledgedResponse> unfollow(final UnfollowIndexAction.Req
7072
return listener;
7173
}
7274

75+
public void putAutoFollowPattern(
76+
final PutAutoFollowPatternAction.Request request,
77+
final ActionListener<AcknowledgedResponse> listener) {
78+
client.execute(PutAutoFollowPatternAction.INSTANCE, request, listener);
79+
}
80+
81+
public ActionFuture<AcknowledgedResponse> putAutoFollowPattern(final PutAutoFollowPatternAction.Request request) {
82+
final PlainActionFuture<AcknowledgedResponse> listener = PlainActionFuture.newFuture();
83+
client.execute(PutAutoFollowPatternAction.INSTANCE, request, listener);
84+
return listener;
85+
}
86+
87+
public void deleteAutoFollowPattern(
88+
final DeleteAutoFollowPatternAction.Request request,
89+
final ActionListener<AcknowledgedResponse> listener) {
90+
client.execute(DeleteAutoFollowPatternAction.INSTANCE, request, listener);
91+
}
92+
93+
public ActionFuture<AcknowledgedResponse> deleteAutoFollowPattern(final DeleteAutoFollowPatternAction.Request request) {
94+
final PlainActionFuture<AcknowledgedResponse> listener = PlainActionFuture.newFuture();
95+
client.execute(DeleteAutoFollowPatternAction.INSTANCE, request, listener);
96+
return listener;
97+
}
98+
7399
}

‎x-pack/plugin/ccr/src/test/java/org/elasticsearch/xpack/ccr/action/DeleteAutoFollowPatternRequestTests.java renamed to ‎x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/ccr/action/DeleteAutoFollowPatternRequestTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
* or more contributor license agreements. Licensed under the Elastic License;
44
* you may not use this file except in compliance with the Elastic License.
55
*/
6-
package org.elasticsearch.xpack.ccr.action;
6+
package org.elasticsearch.xpack.core.ccr.action;
77

88
import org.elasticsearch.test.AbstractStreamableTestCase;
99

‎x-pack/plugin/ccr/src/test/java/org/elasticsearch/xpack/ccr/action/PutAutoFollowPatternRequestTests.java renamed to ‎x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/ccr/action/PutAutoFollowPatternRequestTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
* or more contributor license agreements. Licensed under the Elastic License;
44
* you may not use this file except in compliance with the Elastic License.
55
*/
6-
package org.elasticsearch.xpack.ccr.action;
6+
package org.elasticsearch.xpack.core.ccr.action;
77

88
import org.elasticsearch.common.unit.TimeValue;
99
import org.elasticsearch.common.xcontent.XContentParser;

0 commit comments

Comments
 (0)