Skip to content

Commit ede1681

Browse files
committed
Remove old HLRC base test case (#48714)
This commit finishes cleaning up the AbstractHlrcXContentTestCase work and removes this class. All classes that were using this are now using the updated base class. Ref #39745
1 parent eee4cfa commit ede1681

File tree

4 files changed

+39
-144
lines changed

4 files changed

+39
-144
lines changed

client/rest-high-level/src/test/java/org/elasticsearch/client/AbstractHlrcXContentTestCase.java

-54
This file was deleted.

client/rest-high-level/src/test/java/org/elasticsearch/client/transform/transforms/hlrc/TransformCheckpointingInfoTests.java

+15-36
Original file line numberDiff line numberDiff line change
@@ -19,63 +19,42 @@
1919

2020
package org.elasticsearch.client.transform.transforms.hlrc;
2121

22-
import org.elasticsearch.client.AbstractHlrcXContentTestCase;
22+
import org.elasticsearch.client.AbstractResponseTestCase;
23+
import org.elasticsearch.client.transform.transforms.TransformCheckpointingInfo;
2324
import org.elasticsearch.common.xcontent.XContentParser;
24-
import org.elasticsearch.xpack.core.transform.transforms.TransformCheckpointingInfo;
25+
import org.elasticsearch.common.xcontent.XContentType;
2526

2627
import java.io.IOException;
2728
import java.time.Instant;
28-
import java.util.function.Predicate;
2929

30-
public class TransformCheckpointingInfoTests extends AbstractHlrcXContentTestCase<
31-
TransformCheckpointingInfo,
32-
org.elasticsearch.client.transform.transforms.TransformCheckpointingInfo> {
30+
import static org.elasticsearch.client.transform.transforms.hlrc.TransformStatsTests.assertTransformCheckpointInfo;
3331

34-
public static TransformCheckpointingInfo fromHlrc(
35-
org.elasticsearch.client.transform.transforms.TransformCheckpointingInfo instance) {
36-
return new TransformCheckpointingInfo(
37-
TransformCheckpointStatsTests.fromHlrc(instance.getLast()),
38-
TransformCheckpointStatsTests.fromHlrc(instance.getNext()),
39-
instance.getOperationsBehind(),
40-
instance.getChangesLastDetectedAt());
41-
}
42-
43-
@Override
44-
public org.elasticsearch.client.transform.transforms.TransformCheckpointingInfo doHlrcParseInstance(XContentParser parser) {
45-
return org.elasticsearch.client.transform.transforms.TransformCheckpointingInfo.fromXContent(parser);
46-
}
47-
48-
@Override
49-
public TransformCheckpointingInfo convertHlrcToInternal(
50-
org.elasticsearch.client.transform.transforms.TransformCheckpointingInfo instance) {
51-
return fromHlrc(instance);
52-
}
32+
public class TransformCheckpointingInfoTests extends AbstractResponseTestCase<
33+
org.elasticsearch.xpack.core.transform.transforms.TransformCheckpointingInfo,
34+
TransformCheckpointingInfo> {
5335

54-
public static TransformCheckpointingInfo randomTransformCheckpointingInfo() {
55-
return new TransformCheckpointingInfo(
36+
public static org.elasticsearch.xpack.core.transform.transforms.TransformCheckpointingInfo randomTransformCheckpointingInfo() {
37+
return new org.elasticsearch.xpack.core.transform.transforms.TransformCheckpointingInfo(
5638
TransformCheckpointStatsTests.randomTransformCheckpointStats(),
5739
TransformCheckpointStatsTests.randomTransformCheckpointStats(),
5840
randomNonNegativeLong(),
5941
randomBoolean() ? null : Instant.ofEpochMilli(randomNonNegativeLong()));
6042
}
6143

6244
@Override
63-
protected TransformCheckpointingInfo createTestInstance() {
45+
protected org.elasticsearch.xpack.core.transform.transforms.TransformCheckpointingInfo
46+
createServerTestInstance(XContentType xContentType) {
6447
return randomTransformCheckpointingInfo();
6548
}
6649

6750
@Override
68-
protected TransformCheckpointingInfo doParseInstance(XContentParser parser) throws IOException {
51+
protected TransformCheckpointingInfo doParseToClientInstance(XContentParser parser) throws IOException {
6952
return TransformCheckpointingInfo.fromXContent(parser);
7053
}
7154

7255
@Override
73-
protected boolean supportsUnknownFields() {
74-
return true;
75-
}
76-
77-
@Override
78-
protected Predicate<String> getRandomFieldsExcludeFilter() {
79-
return field -> field.contains("position");
56+
protected void assertInstances(org.elasticsearch.xpack.core.transform.transforms.TransformCheckpointingInfo serverTestInstance,
57+
TransformCheckpointingInfo clientInstance) {
58+
assertTransformCheckpointInfo(serverTestInstance, clientInstance);
8059
}
8160
}

client/rest-high-level/src/test/java/org/elasticsearch/client/transform/transforms/hlrc/TransformIndexerStatsTests.java

+13-44
Original file line numberDiff line numberDiff line change
@@ -19,48 +19,22 @@
1919

2020
package org.elasticsearch.client.transform.transforms.hlrc;
2121

22-
import org.elasticsearch.client.AbstractHlrcXContentTestCase;
22+
import org.elasticsearch.client.AbstractResponseTestCase;
23+
import org.elasticsearch.client.transform.transforms.TransformIndexerStats;
2324
import org.elasticsearch.common.xcontent.XContentParser;
24-
import org.elasticsearch.xpack.core.transform.transforms.TransformIndexerStats;
25+
import org.elasticsearch.common.xcontent.XContentType;
2526

2627
import java.io.IOException;
2728

28-
public class TransformIndexerStatsTests extends AbstractHlrcXContentTestCase<
29-
TransformIndexerStats,
30-
org.elasticsearch.client.transform.transforms.TransformIndexerStats> {
29+
import static org.elasticsearch.client.transform.transforms.hlrc.TransformStatsTests.assertTransformIndexerStats;
3130

32-
public static TransformIndexerStats fromHlrc(
33-
org.elasticsearch.client.transform.transforms.TransformIndexerStats instance) {
34-
return new TransformIndexerStats(
35-
instance.getNumPages(),
36-
instance.getNumDocuments(),
37-
instance.getOutputDocuments(),
38-
instance.getNumInvocations(),
39-
instance.getIndexTime(),
40-
instance.getSearchTime(),
41-
instance.getIndexTotal(),
42-
instance.getSearchTotal(),
43-
instance.getIndexFailures(),
44-
instance.getSearchFailures(),
45-
instance.getExpAvgCheckpointDurationMs(),
46-
instance.getExpAvgDocumentsIndexed(),
47-
instance.getExpAvgDocumentsProcessed());
48-
}
31+
public class TransformIndexerStatsTests extends AbstractResponseTestCase<
32+
org.elasticsearch.xpack.core.transform.transforms.TransformIndexerStats,
33+
TransformIndexerStats> {
4934

5035
@Override
51-
public org.elasticsearch.client.transform.transforms.TransformIndexerStats doHlrcParseInstance(XContentParser parser)
52-
throws IOException {
53-
return org.elasticsearch.client.transform.transforms.TransformIndexerStats.fromXContent(parser);
54-
}
55-
56-
@Override
57-
public TransformIndexerStats convertHlrcToInternal(
58-
org.elasticsearch.client.transform.transforms.TransformIndexerStats instance) {
59-
return fromHlrc(instance);
60-
}
61-
62-
public static TransformIndexerStats randomStats() {
63-
return new TransformIndexerStats(randomLongBetween(10L, 10000L),
36+
protected org.elasticsearch.xpack.core.transform.transforms.TransformIndexerStats createServerTestInstance(XContentType xContentType) {
37+
return new org.elasticsearch.xpack.core.transform.transforms.TransformIndexerStats(randomLongBetween(10L, 10000L),
6438
randomLongBetween(0L, 10000L), randomLongBetween(0L, 10000L), randomLongBetween(0L, 10000L), randomLongBetween(0L, 10000L),
6539
randomLongBetween(0L, 10000L), randomLongBetween(0L, 10000L), randomLongBetween(0L, 10000L), randomLongBetween(0L, 10000L),
6640
randomLongBetween(0L, 10000L),
@@ -70,18 +44,13 @@ public static TransformIndexerStats randomStats() {
7044
}
7145

7246
@Override
73-
protected TransformIndexerStats createTestInstance() {
74-
return randomStats();
75-
}
76-
77-
@Override
78-
protected TransformIndexerStats doParseInstance(XContentParser parser) throws IOException {
47+
protected TransformIndexerStats doParseToClientInstance(XContentParser parser) throws IOException {
7948
return TransformIndexerStats.fromXContent(parser);
8049
}
8150

8251
@Override
83-
protected boolean supportsUnknownFields() {
84-
return true;
52+
protected void assertInstances(org.elasticsearch.xpack.core.transform.transforms.TransformIndexerStats serverTestInstance,
53+
TransformIndexerStats clientInstance) {
54+
assertTransformIndexerStats(serverTestInstance, clientInstance);
8555
}
86-
8756
}

client/rest-high-level/src/test/java/org/elasticsearch/client/transform/transforms/hlrc/TransformStatsTests.java

+11-10
Original file line numberDiff line numberDiff line change
@@ -102,7 +102,7 @@ private void assertNodeAttributes(org.elasticsearch.xpack.core.transform.transfo
102102
assertThat(serverTestInstance.getTransportAddress(), equalTo(clientInstance.getTransportAddress()));
103103
}
104104

105-
private void assertTransformProgress(org.elasticsearch.xpack.core.transform.transforms.TransformProgress serverTestInstance,
105+
public static void assertTransformProgress(org.elasticsearch.xpack.core.transform.transforms.TransformProgress serverTestInstance,
106106
TransformProgress clientInstance) {
107107
if (serverTestInstance == null || clientInstance == null) {
108108
assertNull(serverTestInstance);
@@ -115,34 +115,35 @@ private void assertTransformProgress(org.elasticsearch.xpack.core.transform.tran
115115
assertThat(serverTestInstance.getDocumentsIndexed(), equalTo(clientInstance.getDocumentsIndexed()));
116116
}
117117

118-
private void assertPosition(org.elasticsearch.xpack.core.transform.transforms.TransformIndexerPosition serverTestInstance,
118+
public static void assertPosition(org.elasticsearch.xpack.core.transform.transforms.TransformIndexerPosition serverTestInstance,
119119
TransformIndexerPosition clientInstance) {
120120
assertThat(serverTestInstance.getIndexerPosition(), equalTo(clientInstance.getIndexerPosition()));
121121
assertThat(serverTestInstance.getBucketsPosition(), equalTo(clientInstance.getBucketsPosition()));
122122
}
123123

124124

125-
private void assertTransformCheckpointStats(
126-
org.elasticsearch.xpack.core.transform.transforms.TransformCheckpointStats serverTestInstance,
127-
TransformCheckpointStats clientInstance) {
125+
public static void assertTransformCheckpointStats(
126+
org.elasticsearch.xpack.core.transform.transforms.TransformCheckpointStats serverTestInstance,
127+
TransformCheckpointStats clientInstance) {
128128
assertTransformProgress(serverTestInstance.getCheckpointProgress(), clientInstance.getCheckpointProgress());
129129
assertThat(serverTestInstance.getCheckpoint(), equalTo(clientInstance.getCheckpoint()));
130130
assertPosition(serverTestInstance.getPosition(), clientInstance.getPosition());
131131
assertThat(serverTestInstance.getTimestampMillis(), equalTo(clientInstance.getTimestampMillis()));
132132
assertThat(serverTestInstance.getTimeUpperBoundMillis(), equalTo(clientInstance.getTimeUpperBoundMillis()));
133133
}
134134

135-
private void assertTransformCheckpointInfo(
136-
org.elasticsearch.xpack.core.transform.transforms.TransformCheckpointingInfo serverTestInstance,
137-
TransformCheckpointingInfo clientInstance) {
135+
public static void assertTransformCheckpointInfo(
136+
org.elasticsearch.xpack.core.transform.transforms.TransformCheckpointingInfo serverTestInstance,
137+
TransformCheckpointingInfo clientInstance) {
138138
assertTransformCheckpointStats(serverTestInstance.getNext(), clientInstance.getNext());
139139
assertTransformCheckpointStats(serverTestInstance.getLast(), clientInstance.getLast());
140140
assertThat(serverTestInstance.getChangesLastDetectedAt(), equalTo(clientInstance.getChangesLastDetectedAt()));
141141
assertThat(serverTestInstance.getOperationsBehind(), equalTo(clientInstance.getOperationsBehind()));
142142
}
143143

144-
private void assertTransformIndexerStats(org.elasticsearch.xpack.core.transform.transforms.TransformIndexerStats serverTestInstance,
145-
TransformIndexerStats clientInstance) {
144+
public static void assertTransformIndexerStats(
145+
org.elasticsearch.xpack.core.transform.transforms.TransformIndexerStats serverTestInstance,
146+
TransformIndexerStats clientInstance) {
146147
assertThat(serverTestInstance.getExpAvgCheckpointDurationMs(), equalTo(clientInstance.getExpAvgCheckpointDurationMs()));
147148
assertThat(serverTestInstance.getExpAvgDocumentsProcessed(), equalTo(clientInstance.getExpAvgDocumentsProcessed()));
148149
assertThat(serverTestInstance.getExpAvgDocumentsIndexed(), equalTo(clientInstance.getExpAvgDocumentsIndexed()));

0 commit comments

Comments
 (0)