continuous-load-testing: Fix Issues with CloudPath Enablement

continuous_load_testing/Dockerfile

@@ -1,5 +1,5 @@
 FROM eclipse-temurin
 COPY build/install/continuous_load_testing /app
 # Uncomment the line below to enable CloudPath instead of DirectPath
-# ENV GOOGLE_CLOUD_DISABLE_DIRECT_PATH=true
+# ENV DISABLE_DIRECT_PATH=true
 CMD /app/bin/continuous_load_testing --methods=EmptyCall --concurrency=1

continuous_load_testing/client-java-cloudpath.yaml

@@ -30,7 +30,7 @@ spec:
               fieldPath: metadata.namespace
         - name: CONTAINER_NAME
           value: client-java-cloudpath
-        - name: GOOGLE_CLOUD_DISABLE_DIRECT_PATH
+        - name: DISABLE_DIRECT_PATH
           value: "true"
         - name: OTEL_RESOURCE_ATTRIBUTES
           value: k8s.pod.name=$(POD_NAME),k8s.namespace.name=$(NAMESPACE_NAME),k8s.container.name=$(CONTAINER_NAME)

continuous_load_testing/src/main/java/com/google/net/grpc/testing/directpath/continuous_load_testing/Client.java

@@ -45,7 +45,8 @@ private enum Method {
   }
 
   private static final Logger logger = Logger.getLogger(Client.class.getName());
-  private static final String BACKEND = "google-c2p:///directpathgrpctesting-pa.googleapis.com";
+  private static final String DIRECTPATH_BACKEND = "google-c2p:///directpathgrpctesting-pa.googleapis.com";
+  private static final String CLOUDPATH_BACKEND = "dns:///directpathgrpctesting-pa.googleapis.com";
   private static final Set<Method> methods = new HashSet<>(Arrays.asList(Method.values()));
   private static int concurrency = 1;
   private static int num_of_requests = 10;
@@ -79,6 +80,13 @@ public static void main(String[] args) {
     GrpcOpenTelemetry grpcOpenTelemetry = initializeOpenTelemetry();
 
     ChannelCredentials credentials = GoogleDefaultChannelCredentials.create();
+    String disableDirectPath = System.getenv("DISABLE_DIRECT_PATH");
+    String BACKEND;
+    if ("true".equals(disableDirectPath)) {
+      BACKEND = CLOUDPATH_BACKEND;
+    } else {
+      BACKEND = DIRECTPATH_BACKEND;
+    }
     ManagedChannelBuilder<?> builder = Grpc.newChannelBuilder(BACKEND, credentials);
     grpcOpenTelemetry.configureChannelBuilder(builder);
     TestServiceStub stub = TestServiceGrpc.newStub(builder.build());