Add KubernetesEndpointGroup

kubernetes/build.gradle.kts

@@ -3,4 +3,5 @@ dependencies {
     api(libs.kubernetes.client.impl)
     testImplementation(variantOf(libs.kubernetes.client.api) { classifier("tests") })
     testImplementation(libs.kubernetes.server.mock)
+    testImplementation(libs.kubernetes.junit.jupiter)
 }

kubernetes/src/main/java/com/linecorp/armeria/client/kubernetes/ArmeriaHttpClient.java

@@ -93,7 +93,7 @@ public CompletableFuture<HttpResponse<AsyncBody>> consumeBytesDirect(
         return splitResponse.headers().thenApply(responseHeaders -> {
             final AsyncBodySubscriber subscriber = new AsyncBodySubscriber(consumer);
             splitResponse.body().subscribe(subscriber, ctx.eventLoop());
-            return new ArmeriaHttpResponse(responseHeaders, subscriber);
+            return new ArmeriaHttpResponse(request, responseHeaders, subscriber);
         });
     }
 

kubernetes/src/main/java/com/linecorp/armeria/client/kubernetes/ArmeriaHttpResponse.java

@@ -29,17 +29,20 @@
 import io.fabric8.kubernetes.client.http.AsyncBody;
 import io.fabric8.kubernetes.client.http.HttpRequest;
 import io.fabric8.kubernetes.client.http.HttpResponse;
+import io.fabric8.kubernetes.client.http.StandardHttpRequest;
 import io.netty.util.AsciiString;
 
 final class ArmeriaHttpResponse implements HttpResponse<AsyncBody> {
 
+    private final StandardHttpRequest request;
     private final ResponseHeaders responseHeaders;
     private final AsyncBody body;
 
     @Nullable
     private Map<String, List<String>> headers;
 
-    ArmeriaHttpResponse(ResponseHeaders responseHeaders, AsyncBody body) {
+    ArmeriaHttpResponse(StandardHttpRequest request, ResponseHeaders responseHeaders, AsyncBody body) {
+        this.request = request;
         this.responseHeaders = responseHeaders;
         this.body = body;
     }
@@ -61,7 +64,7 @@ public AsyncBody body() {
 
     @Override
     public HttpRequest request() {
-        return null;
+        return request;
     }
 
     @Override