Skip to content

Commit ecfbe51

Browse files
committed
Add HTTP/2 protocol support to HttpRequest.HttpVersion
Signed-off-by: Andriy Redko <[email protected]>
1 parent b82ed5a commit ecfbe51

File tree

3 files changed

+6
-1
lines changed

3 files changed

+6
-1
lines changed

modules/transport-netty4/src/main/java/org/opensearch/http/netty4/Netty4HttpRequest.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -217,6 +217,8 @@ public HttpVersion protocolVersion() {
217217
return HttpRequest.HttpVersion.HTTP_1_0;
218218
} else if (request.protocolVersion().equals(io.netty.handler.codec.http.HttpVersion.HTTP_1_1)) {
219219
return HttpRequest.HttpVersion.HTTP_1_1;
220+
} else if (request.protocolVersion().equals("HTTP/2.0")) {
221+
return HttpRequest.HttpVersion.HTTP_2_0;
220222
} else {
221223
throw new IllegalArgumentException("Unexpected http protocol version: " + request.protocolVersion());
222224
}

plugins/transport-reactor-netty4/src/main/java/org/opensearch/http/reactor/netty4/ReactorNetty4HttpRequest.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -156,6 +156,8 @@ public HttpVersion protocolVersion() {
156156
return HttpRequest.HttpVersion.HTTP_1_0;
157157
} else if (protocol.equals(io.netty.handler.codec.http.HttpVersion.HTTP_1_1.toString())) {
158158
return HttpRequest.HttpVersion.HTTP_1_1;
159+
} else if (protocol.equals("HTTP/2.0")) {
160+
return HttpRequest.HttpVersion.HTTP_2_0;
159161
} else {
160162
throw new IllegalArgumentException("Unexpected http protocol version: " + protocol);
161163
}

server/src/main/java/org/opensearch/http/HttpRequest.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,8 @@ public interface HttpRequest {
5959
@PublicApi(since = "1.0.0")
6060
enum HttpVersion {
6161
HTTP_1_0,
62-
HTTP_1_1
62+
HTTP_1_1,
63+
HTTP_2_0
6364
}
6465

6566
/**

0 commit comments

Comments
 (0)