xds: add xds end to end interop test (grpc#8618)

Add AbstractXdsInteropTest, XdsTestControlPlaneService and only ping-pong testcase in initial implementation.
AbstractXdsInteropTest sets up the test control plane, create xdsClient and xdServer using bootstrap override, test case extending AbstractXdsInteropTest is supposed to override the control plane config and run the verification.

XdsTestControlPlaneService only has static xds configurations, not able to keep states.

How to run:
 ./gradlew :grpc-interop-testing:installDist -PskipCodegen=true
 ./interop-testing/build/install/grpc-interop-testing/bin/xds-e2e-test-client

interop-testing/build.gradle

@@ -147,6 +147,13 @@ task xds_test_server(type: CreateStartScripts) {
     classpath = startScripts.classpath
 }
 
+task xds_e2e_client(type: CreateStartScripts) {
+    mainClassName = "io.grpc.testing.integration.XdsInteropTest"
+    applicationName = "xds-e2e-test-client"
+    outputDir = new File(project.buildDir, 'tmp/scripts/' + name)
+    classpath = startScripts.classpath
+}
+
 applicationDistribution.into("bin") {
     from(test_client)
     from(test_server)
@@ -157,6 +164,7 @@ applicationDistribution.into("bin") {
     from(grpclb_fallback_test_client)
     from(xds_test_client)
     from(xds_test_server)
+    from(xds_e2e_client)
     fileMode = 0755
 }
 

interop-testing/src/main/java/io/grpc/testing/integration/AbstractXdsInteropTest.java

@@ -0,0 +1,337 @@
+/*
+ * Copyright 2021 The gRPC Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package io.grpc.testing.integration;
+
+import com.google.common.collect.ImmutableMap;
+import com.google.common.util.concurrent.MoreExecutors;
+import com.google.protobuf.Any;
+import com.google.protobuf.UInt32Value;
+import io.grpc.Grpc;
+import io.grpc.InsecureChannelCredentials;
+import io.grpc.InsecureServerCredentials;
+import io.grpc.ManagedChannel;
+import io.grpc.NameResolverRegistry;
+import io.grpc.Server;
+import io.grpc.netty.NettyServerBuilder;
+import io.grpc.xds.XdsNameResolverProvider;
+import io.grpc.xds.XdsServerBuilder;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.config.cluster.v3.Cluster;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.config.core.v3.Address;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.config.core.v3.AggregatedConfigSource;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.config.core.v3.ConfigSource;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.config.core.v3.HealthStatus;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.config.core.v3.SocketAddress;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.config.core.v3.TrafficDirection;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.config.endpoint.v3.ClusterLoadAssignment;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.config.endpoint.v3.Endpoint;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.config.endpoint.v3.LbEndpoint;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.config.endpoint.v3.LocalityLbEndpoints;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.config.listener.v3.ApiListener;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.config.listener.v3.Filter;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.config.listener.v3.FilterChain;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.config.listener.v3.FilterChainMatch;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.config.listener.v3.Listener;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.config.route.v3.NonForwardingAction;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.config.route.v3.Route;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.config.route.v3.RouteAction;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.config.route.v3.RouteConfiguration;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.config.route.v3.RouteMatch;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.config.route.v3.VirtualHost;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.extensions.filters.http.router.v3.Router;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.extensions.filters.network.http_connection_manager.v3.HttpConnectionManager;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.extensions.filters.network.http_connection_manager.v3.HttpFilter;
+import io.grpc.xds.shaded.io.envoyproxy.envoy.extensions.filters.network.http_connection_manager.v3.Rds;
+
+import java.util.Collections;
+import java.util.Map;
+import java.util.UUID;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+
+/**
+ * Abstract base class for end-to-end xds tests.
+ * A local control plane is implemented in {@link XdsTestControlPlaneService}.
+ * Test cases can inject xds configs to the control plane for testing.
+ */
+public abstract class AbstractXdsInteropTest {
+  private static final Logger logger = Logger.getLogger(AbstractXdsInteropTest.class.getName());
+
+  protected static final int testServerPort = 8080;
+  private static final int controlPlaneServicePort = 443;
+  private Server server;
+  private Server controlPlane;
+  protected TestServiceGrpc.TestServiceBlockingStub blockingStub;
+  private ScheduledExecutorService executor;
+  private XdsNameResolverProvider nameResolverProvider;
+  private static final String scheme = "test-xds";
+  private static final String serverHostName = "0.0.0.0:" + testServerPort;
+  private static final String SERVER_LISTENER_TEMPLATE =
+      "grpc/server?udpa.resource.listening_address=%s";
+  private static final String rdsName = "route-config.googleapis.com";
+  private static final String clusterName = "cluster0";
+  private static final String edsName = "eds-service-0";
+  private static final String HTTP_CONNECTION_MANAGER_TYPE_URL =
+      "type.googleapis.com/envoy.extensions.filters.network.http_connection_manager.v3"
+          + ".HttpConnectionManager";
+
+  private static final Map<String, ?> defaultClientBootstrapOverride = ImmutableMap.of(
+      "node", ImmutableMap.of(
+          "id", UUID.randomUUID().toString(),
+          "cluster", "cluster0"),
+      "xds_servers", Collections.singletonList(
+          ImmutableMap.of(
+              "server_uri", "localhost:" + controlPlaneServicePort,
+              "channel_creds", Collections.singletonList(
+                  ImmutableMap.of("type", "insecure")
+              ),
+              "server_features", Collections.singletonList("xds_v3")
+          )
+      )
+  );
+
+  /**
+   * Provides default client bootstrap.
+   * A subclass test case should override this method if it tests client bootstrap.
+   */
+  protected Map<String, ?> getClientBootstrapOverride() {
+    return defaultClientBootstrapOverride;
+  }
+
+  private static final Map<String, ?> defaultServerBootstrapOverride = ImmutableMap.of(
+      "node", ImmutableMap.of(
+          "id", UUID.randomUUID().toString()),
+      "xds_servers", Collections.singletonList(
+          ImmutableMap.of(
+              "server_uri", "localhost:" + controlPlaneServicePort,
+              "channel_creds", Collections.singletonList(
+                  ImmutableMap.of("type", "insecure")
+              ),
+              "server_features", Collections.singletonList("xds_v3")
+          )
+      ),
+      "server_listener_resource_name_template", SERVER_LISTENER_TEMPLATE
+  );
+
+  /**
+   * Provides default server bootstrap.
+   * A subclass test case should override this method if it tests server bootstrap.
+   */
+  protected Map<String, ?> getServerBootstrapOverride() {
+    return defaultServerBootstrapOverride;
+  }
+
+  protected void setUp() throws Exception {
+    startControlPlane();
+    startServer();
+    nameResolverProvider = XdsNameResolverProvider.createForTest(scheme,
+        getClientBootstrapOverride());
+    NameResolverRegistry.getDefaultRegistry().register(nameResolverProvider);
+    ManagedChannel channel = Grpc.newChannelBuilder(scheme + ":///" + serverHostName,
+        InsecureChannelCredentials.create()).build();
+    blockingStub = TestServiceGrpc.newBlockingStub(channel);
+  }
+
+  protected void tearDown() throws Exception {
+    if (server != null) {
+      server.shutdownNow();
+      if (!server.awaitTermination(5, TimeUnit.SECONDS)) {
+        logger.log(Level.SEVERE, "Timed out waiting for server shutdown");
+      }
+    }
+    if (controlPlane != null) {
+      controlPlane.shutdownNow();
+      if (!controlPlane.awaitTermination(5, TimeUnit.SECONDS)) {
+        logger.log(Level.SEVERE, "Timed out waiting for server shutdown");
+      }
+    }
+    if (executor != null) {
+      MoreExecutors.shutdownAndAwaitTermination(executor, 5, TimeUnit.SECONDS);
+    }
+    NameResolverRegistry.getDefaultRegistry().deregister(nameResolverProvider);
+  }
+
+  protected void startServer() throws Exception {
+    executor = Executors.newSingleThreadScheduledExecutor();
+    XdsServerBuilder serverBuilder = XdsServerBuilder.forPort(
+        testServerPort, InsecureServerCredentials.create())
+        .addService(new TestServiceImpl(executor))
+        .overrideBootstrapForTest(getServerBootstrapOverride());
+    server = serverBuilder.build().start();
+  }
+
+  /**
+   * Provides default control plane xds configs.
+   * A subclass test case should override this method to inject control plane xds configs to verify
+   * end-to-end behavior.
+   */
+  protected XdsTestControlPlaneService.XdsTestControlPlaneConfig getControlPlaneConfig() {
+    String tcpListenerName = SERVER_LISTENER_TEMPLATE.replaceAll("%s", serverHostName);
+    return new XdsTestControlPlaneService.XdsTestControlPlaneConfig(
+        Collections.singletonList(serverListener(tcpListenerName, serverHostName)),
+        Collections.singletonList(clientListener(serverHostName)),
+        Collections.singletonList(rds(serverHostName)),
+        Collections.singletonList(cds()),
+        Collections.singletonList(eds(testServerPort))
+    );
+  }
+
+  private void startControlPlane() throws Exception {
+    XdsTestControlPlaneService.XdsTestControlPlaneConfig controlPlaneConfig =
+        getControlPlaneConfig();
+    logger.log(Level.FINER, "Starting control plane with config: {0}", controlPlaneConfig);
+    XdsTestControlPlaneService controlPlaneService = new XdsTestControlPlaneService(
+        controlPlaneConfig);
+    NettyServerBuilder controlPlaneServerBuilder =
+        NettyServerBuilder.forPort(controlPlaneServicePort)
+        .addService(controlPlaneService);
+    controlPlane = controlPlaneServerBuilder.build().start();
+  }
+
+  /**
+   * A subclass test case should override this method to verify end-to-end behaviour.
+   */
+  abstract void run();
+
+  private static Listener clientListener(String name) {
+    HttpFilter httpFilter = HttpFilter.newBuilder()
+        .setName("terminal-filter")
+        .setTypedConfig(Any.pack(Router.newBuilder().build()))
+        .setIsOptional(true)
+        .build();
+    ApiListener apiListener = ApiListener.newBuilder().setApiListener(Any.pack(
+        HttpConnectionManager.newBuilder()
+            .setRds(
+                Rds.newBuilder()
+                    .setRouteConfigName(rdsName)
+                    .setConfigSource(
+                        ConfigSource.newBuilder()
+                            .setAds(AggregatedConfigSource.getDefaultInstance())))
+            .addAllHttpFilters(Collections.singletonList(httpFilter))
+            .build(),
+        HTTP_CONNECTION_MANAGER_TYPE_URL)
+    ).build();
+    Listener listener = Listener.newBuilder()
+        .setName(name)
+        .setApiListener(apiListener).build();
+    return listener;
+  }
+
+  private static Listener serverListener(String name, String authority) {
+    HttpFilter routerFilter = HttpFilter.newBuilder()
+        .setName("terminal-filter")
+        .setTypedConfig(
+            Any.pack(Router.newBuilder().build()))
+        .setIsOptional(true)
+        .build();
+    VirtualHost virtualHost = VirtualHost.newBuilder()
+        .setName("virtual-host-0")
+        .addDomains(authority)
+        .addRoutes(
+            Route.newBuilder()
+                .setMatch(
+                    RouteMatch.newBuilder().setPrefix("/").build()
+                )
+                .setNonForwardingAction(NonForwardingAction.newBuilder().build())
+                .build()
+        ).build();
+    RouteConfiguration routeConfig = RouteConfiguration.newBuilder()
+        .addVirtualHosts(virtualHost)
+        .build();
+    Filter filter = Filter.newBuilder()
+        .setName("network-filter-0")
+        .setTypedConfig(
+            Any.pack(
+                HttpConnectionManager.newBuilder()
+                    .setRouteConfig(routeConfig)
+                    .addAllHttpFilters(Collections.singletonList(routerFilter))
+                    .build()
+            )
+        ).build();
+    FilterChainMatch filterChainMatch = FilterChainMatch.newBuilder()
+        .setSourceType(FilterChainMatch.ConnectionSourceType.ANY)
+        .build();
+    FilterChain filterChain = FilterChain.newBuilder()
+        .setName("filter-chain-0")
+        .setFilterChainMatch(filterChainMatch)
+        .addFilters(filter)
+        .build();
+    return Listener.newBuilder()
+        .setName(name)
+        .setTrafficDirection(TrafficDirection.INBOUND)
+        .addFilterChains(filterChain)
+        .build();
+  }
+
+  private static RouteConfiguration rds(String authority) {
+    VirtualHost virtualHost = VirtualHost.newBuilder()
+        .addDomains(authority)
+        .addRoutes(
+            Route.newBuilder()
+                .setMatch(
+                    RouteMatch.newBuilder().setPrefix("/").build()
+                )
+                .setRoute(
+                    RouteAction.newBuilder().setCluster(clusterName).build()
+                )
+                .build())
+        .build();
+    return RouteConfiguration.newBuilder().setName(rdsName).addVirtualHosts(virtualHost).build();
+  }
+
+  private static Cluster cds() {
+    return Cluster.newBuilder()
+        .setName(clusterName)
+        .setType(Cluster.DiscoveryType.EDS)
+        .setEdsClusterConfig(
+            Cluster.EdsClusterConfig.newBuilder()
+                .setServiceName(edsName)
+                .setEdsConfig(
+                    ConfigSource.newBuilder()
+                        .setAds(AggregatedConfigSource.newBuilder().build())
+                        .build())
+                .build()
+        )
+        .setLbPolicy(Cluster.LbPolicy.ROUND_ROBIN)
+        .build();
+  }
+
+  private static ClusterLoadAssignment eds(int port) {
+    Address address = Address.newBuilder()
+        .setSocketAddress(
+            SocketAddress.newBuilder().setAddress("0.0.0.0").setPortValue(port).build()
+        )
+        .build();
+    LocalityLbEndpoints endpoints = LocalityLbEndpoints.newBuilder()
+        .setLoadBalancingWeight(UInt32Value.of(10))
+        .setPriority(0)
+        .addLbEndpoints(
+            LbEndpoint.newBuilder()
+                .setEndpoint(
+                    Endpoint.newBuilder().setAddress(address).build())
+                .setHealthStatus(HealthStatus.HEALTHY)
+                .build()
+        )
+        .build();
+    return ClusterLoadAssignment.newBuilder()
+        .setClusterName(edsName)
+        .addEndpoints(endpoints)
+        .build();
+  }
+}