Skip to content

Commit 530e42f

Browse files
authored
Migrate transport version 9156_000 (#134671)
ES-12334
1 parent 2527c75 commit 530e42f

File tree

5 files changed

+10
-6
lines changed

5 files changed

+10
-6
lines changed

server/src/main/java/org/elasticsearch/TransportVersions.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -321,7 +321,6 @@ static TransportVersion def(int id) {
321321
public static final TransportVersion ML_INFERENCE_ELASTIC_DENSE_TEXT_EMBEDDINGS_ADDED = def(9_109_00_0);
322322
public static final TransportVersion ML_INFERENCE_COHERE_API_VERSION = def(9_110_0_00);
323323
public static final TransportVersion ESQL_PROFILE_INCLUDE_PLAN = def(9_111_0_00);
324-
public static final TransportVersion INFERENCE_API_EIS_DIAGNOSTICS = def(9_156_0_00);
325324
public static final TransportVersion ML_INFERENCE_ENDPOINT_CACHE = def(9_157_0_00);
326325
public static final TransportVersion INDEX_SOURCE = def(9_158_0_00);
327326
public static final TransportVersion MAX_HEAP_SIZE_PER_NODE_IN_CLUSTER_INFO = def(9_159_0_00);
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
9156000
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
time_series_telemetry,9155000
1+
inference_api_eis_diagnostics,9156000

x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/inference/action/GetInferenceDiagnosticsAction.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88
package org.elasticsearch.xpack.core.inference.action;
99

1010
import org.apache.http.pool.PoolStats;
11-
import org.elasticsearch.TransportVersions;
11+
import org.elasticsearch.TransportVersion;
1212
import org.elasticsearch.action.ActionType;
1313
import org.elasticsearch.action.FailedNodeException;
1414
import org.elasticsearch.action.support.nodes.BaseNodeResponse;
@@ -35,6 +35,7 @@ public class GetInferenceDiagnosticsAction extends ActionType<GetInferenceDiagno
3535

3636
public static final GetInferenceDiagnosticsAction INSTANCE = new GetInferenceDiagnosticsAction();
3737
public static final String NAME = "cluster:monitor/xpack/inference/diagnostics/get";
38+
private static final TransportVersion INFERENCE_API_EIS_DIAGNOSTICS = TransportVersion.fromName("inference_api_eis_diagnostics");
3839

3940
public GetInferenceDiagnosticsAction() {
4041
super(NAME);
@@ -145,7 +146,7 @@ public NodeResponse(StreamInput in) throws IOException {
145146
super(in);
146147

147148
externalConnectionPoolStats = new ConnectionPoolStats(in);
148-
if (in.getTransportVersion().onOrAfter(TransportVersions.INFERENCE_API_EIS_DIAGNOSTICS)) {
149+
if (in.getTransportVersion().supports(INFERENCE_API_EIS_DIAGNOSTICS)) {
149150
eisMtlsConnectionPoolStats = new ConnectionPoolStats(in);
150151
} else {
151152
eisMtlsConnectionPoolStats = ConnectionPoolStats.EMPTY;
@@ -160,7 +161,7 @@ public void writeTo(StreamOutput out) throws IOException {
160161
super.writeTo(out);
161162
externalConnectionPoolStats.writeTo(out);
162163

163-
if (out.getTransportVersion().onOrAfter(TransportVersions.INFERENCE_API_EIS_DIAGNOSTICS)) {
164+
if (out.getTransportVersion().supports(INFERENCE_API_EIS_DIAGNOSTICS)) {
164165
eisMtlsConnectionPoolStats.writeTo(out);
165166
}
166167
if (out.getTransportVersion().onOrAfter(ML_INFERENCE_ENDPOINT_CACHE)) {

x-pack/plugin/core/src/test/java/org/elasticsearch/xpack/core/inference/action/GetInferenceDiagnosticsActionNodeResponseTests.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,9 @@
2121

2222
public class GetInferenceDiagnosticsActionNodeResponseTests extends AbstractBWCWireSerializationTestCase<
2323
GetInferenceDiagnosticsAction.NodeResponse> {
24+
25+
private static final TransportVersion INFERENCE_API_EIS_DIAGNOSTICS = TransportVersion.fromName("inference_api_eis_diagnostics");
26+
2427
public static GetInferenceDiagnosticsAction.NodeResponse createRandom() {
2528
DiscoveryNode node = DiscoveryNodeUtils.create("id");
2629
var randomExternalPoolStats = new PoolStats(randomInt(), randomInt(), randomInt(), randomInt());
@@ -109,7 +112,7 @@ public static GetInferenceDiagnosticsAction.NodeResponse mutateNodeResponseForVe
109112
return instance;
110113
}
111114

112-
var eisMltsConnectionPoolStats = version.onOrAfter(TransportVersions.INFERENCE_API_EIS_DIAGNOSTICS)
115+
var eisMltsConnectionPoolStats = version.supports(INFERENCE_API_EIS_DIAGNOSTICS)
113116
? new PoolStats(
114117
instance.getEisMtlsConnectionPoolStats().getLeasedConnections(),
115118
instance.getEisMtlsConnectionPoolStats().getPendingConnections(),

0 commit comments

Comments
 (0)