mirror of
https://github.com/elastic/elasticsearch.git
synced 2025-04-24 23:27:25 -04:00
Collapse 8.16.1 transport versions (#124003)
This commit is contained in:
parent
025acaa603
commit
3b323dc588
5 changed files with 8 additions and 11 deletions
|
@ -68,7 +68,7 @@ public class QueryRulesetListItem implements Writeable, ToXContentObject {
|
|||
this.criteriaTypeToCountMap = Map.of();
|
||||
}
|
||||
TransportVersion streamTransportVersion = in.getTransportVersion();
|
||||
if (streamTransportVersion.isPatchFrom(TransportVersions.QUERY_RULES_LIST_INCLUDES_TYPES_BACKPORT_8_16)
|
||||
if (streamTransportVersion.isPatchFrom(TransportVersions.V_8_16_1)
|
||||
|| streamTransportVersion.onOrAfter(TransportVersions.QUERY_RULES_LIST_INCLUDES_TYPES)) {
|
||||
this.ruleTypeToCountMap = in.readMap(m -> in.readEnum(QueryRule.QueryRuleType.class), StreamInput::readInt);
|
||||
} else {
|
||||
|
@ -103,7 +103,7 @@ public class QueryRulesetListItem implements Writeable, ToXContentObject {
|
|||
out.writeMap(criteriaTypeToCountMap, StreamOutput::writeEnum, StreamOutput::writeInt);
|
||||
}
|
||||
TransportVersion streamTransportVersion = out.getTransportVersion();
|
||||
if (streamTransportVersion.isPatchFrom(TransportVersions.QUERY_RULES_LIST_INCLUDES_TYPES_BACKPORT_8_16)
|
||||
if (streamTransportVersion.isPatchFrom(TransportVersions.V_8_16_1)
|
||||
|| streamTransportVersion.onOrAfter(TransportVersions.QUERY_RULES_LIST_INCLUDES_TYPES)) {
|
||||
out.writeMap(ruleTypeToCountMap, StreamOutput::writeEnum, StreamOutput::writeInt);
|
||||
}
|
||||
|
|
|
@ -59,8 +59,7 @@ public class ListQueryRulesetsActionResponseBWCSerializingTests extends Abstract
|
|||
ListQueryRulesetsAction.Response instance,
|
||||
TransportVersion version
|
||||
) {
|
||||
if (version.isPatchFrom(TransportVersions.QUERY_RULES_LIST_INCLUDES_TYPES_BACKPORT_8_16)
|
||||
|| version.onOrAfter(TransportVersions.QUERY_RULES_LIST_INCLUDES_TYPES)) {
|
||||
if (version.isPatchFrom(TransportVersions.V_8_16_1) || version.onOrAfter(TransportVersions.QUERY_RULES_LIST_INCLUDES_TYPES)) {
|
||||
return instance;
|
||||
} else if (version.onOrAfter(QueryRulesetListItem.EXPANDED_RULESET_COUNT_TRANSPORT_VERSION)) {
|
||||
List<QueryRulesetListItem> updatedResults = new ArrayList<>();
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue