Skip to content

Commit

Permalink
Advance TransportVersion for plugin (elastic#97026)
Browse files Browse the repository at this point in the history
In the stateless plugin we need to advance transport version for a serialization change.
  • Loading branch information
Tim-Brooks committed Jun 23, 2023
1 parent 6db1a8d commit 6e6fd92
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion server/src/main/java/org/elasticsearch/TransportVersion.java
Original file line number Diff line number Diff line change
Expand Up @@ -131,6 +131,7 @@ private static TransportVersion registerTransportVersion(int id, String uniqueId
public static final TransportVersion V_8_500_005 = registerTransportVersion(8_500_005, "65370d2a-d936-4383-a2e0-8403f708129b");
public static final TransportVersion V_8_500_006 = registerTransportVersion(8_500_006, "7BB5621A-80AC-425F-BA88-75543C442F23");
public static final TransportVersion V_8_500_007 = registerTransportVersion(8_500_007, "77261d43-4149-40af-89c5-7e71e0454fce");
// Introduced for stateless plugin
public static final TransportVersion V_8_500_008 = registerTransportVersion(8_500_008, "8884ab9d-94cd-4bac-aff8-01f2c394f47c");

public static final TransportVersion V_8_500_009 = registerTransportVersion(8_500_009, "35091358-fd41-4106-a6e2-d2a1315494c1");
Expand All @@ -147,9 +148,11 @@ private static TransportVersion registerTransportVersion(int id, String uniqueId
// 8.9.0
public static final TransportVersion V_8_500_020 = registerTransportVersion(8_500_020, "ECB42C26-B258-42E5-A835-E31AF84A76DE");
public static final TransportVersion V_8_500_021 = registerTransportVersion(8_500_021, "102e0d84-0c08-402c-a696-935f3a3da873");
// Introduced for stateless plugin
public static final TransportVersion V_8_500_022 = registerTransportVersion(8_500_022, "4993c724-7a81-4955-84e7-403484610091");

private static class CurrentHolder {
private static final TransportVersion CURRENT = findCurrent(V_8_500_021);
private static final TransportVersion CURRENT = findCurrent(V_8_500_022);

// finds the pluggable current version, or uses the given fallback
private static TransportVersion findCurrent(TransportVersion fallback) {
Expand Down

0 comments on commit 6e6fd92

Please sign in to comment.