Skip to content

Commit ce1b749

Browse files
Handle projectRouting over the wire
1 parent 0ba6198 commit ce1b749

File tree

3 files changed

+13
-1
lines changed

3 files changed

+13
-1
lines changed

server/src/main/java/org/elasticsearch/action/search/MultiSearchRequest.java

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99

1010
package org.elasticsearch.action.search;
1111

12+
import org.elasticsearch.TransportVersion;
1213
import org.elasticsearch.action.ActionRequestValidationException;
1314
import org.elasticsearch.action.CompositeIndicesRequest;
1415
import org.elasticsearch.action.IndicesRequest;
@@ -62,6 +63,8 @@ public class MultiSearchRequest extends LegacyActionRequest implements Composite
6263
@Nullable
6364
private String projectRouting;
6465

66+
private static final TransportVersion MSEARCH_PROJECT_ROUTING = TransportVersion.fromName("msearch_project_routing");
67+
6568
public MultiSearchRequest() {}
6669

6770
/**
@@ -141,13 +144,21 @@ public MultiSearchRequest(StreamInput in) throws IOException {
141144
SearchRequest request = new SearchRequest(in);
142145
requests.add(request);
143146
}
147+
if (in.getTransportVersion().supports(MSEARCH_PROJECT_ROUTING)) {
148+
this.projectRouting = in.readOptionalString();
149+
} else {
150+
this.projectRouting = null;
151+
}
144152
}
145153

146154
@Override
147155
public void writeTo(StreamOutput out) throws IOException {
148156
super.writeTo(out);
149157
out.writeVInt(maxConcurrentSearchRequests);
150158
out.writeCollection(requests);
159+
if (out.getTransportVersion().supports(MSEARCH_PROJECT_ROUTING)) {
160+
out.writeOptionalString(this.projectRouting);
161+
}
151162
}
152163

153164
@Override
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
9234000
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
ml_inference_nvidia_added,9233000
1+
msearch_project_routing,9234000

0 commit comments

Comments
 (0)