Enh 37136318 - Add a metrics test for Executor (main -> ce-main @112229)

[git-p4: depot-paths = "//dev/coherence-ce/main/": change = 112260]

Author: lsho

prj/test/functional/executor/pom.xml

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!--
-  Copyright (c) 2000, 2022, Oracle and/or its affiliates.
+  Copyright (c) 2000, 2024, Oracle and/or its affiliates.
 
   Licensed under the Universal Permissive License v 1.0 as shown at
   https://oss.oracle.com/licenses/upl.
@@ -40,6 +40,12 @@
       <artifactId>coherence-testing-support</artifactId>
       <version>${project.version}</version>
     </dependency>
+    <dependency>
+      <groupId>com.oracle.coherence.ce.tests</groupId>
+      <artifactId>metrics</artifactId>
+      <version>${project.version}</version>
+      <scope>compile</scope>
+    </dependency>
 
     <dependency>
       <groupId>org.glassfish.jersey.core</groupId>

prj/test/functional/executor/src/main/java/executor/CESJavaSingleClusterTests.java

@@ -1,5 +1,5 @@
 /*
- * Copyright (c) 2000, 2023, Oracle and/or its affiliates.
+ * Copyright (c) 2000, 2024, Oracle and/or its affiliates.
  *
  * Licensed under the Universal Permissive License v 1.0 as shown at
  * https://oss.oracle.com/licenses/upl.
@@ -18,25 +18,38 @@
 import com.oracle.bedrock.runtime.coherence.options.RoleName;
 
 import com.oracle.bedrock.runtime.java.features.JmxFeature;
-
 import com.oracle.bedrock.runtime.java.options.ClassName;
 import com.oracle.bedrock.runtime.java.options.SystemProperty;
 
 import com.oracle.bedrock.runtime.options.DisplayName;
-
 import com.oracle.bedrock.runtime.options.StabilityPredicate;
+import com.oracle.bedrock.testsupport.deferred.Eventually;
+
+import com.tangosol.internal.net.metrics.MetricsHttpHelper;
 import com.tangosol.net.Coherence;
 
 import executor.common.CoherenceClusterResource;
 import executor.common.LogOutput;
 import executor.common.SingleClusterForAllTests;
+import executor.common.Utils;
+
+import metrics.AbstractMetricsFunctionalTest;
+
+import java.util.LinkedHashMap;
+import java.util.Map;
+
+import org.hamcrest.CoreMatchers;
 
-import org.junit.AfterClass;
 import org.junit.BeforeClass;
 import org.junit.ClassRule;
-
+import org.junit.Test;
 import org.junit.experimental.categories.Category;
 
+import static com.oracle.bedrock.deferred.DeferredHelper.invoking;
+import static org.hamcrest.Matchers.greaterThan;
+import static org.junit.Assert.fail;
+
+
 /**
  * Tests will spin up a cluster shared by each test using java as the serialization
  * format.
@@ -78,10 +91,34 @@ public String getLabel()
         return CESJavaSingleClusterTests.class.getSimpleName();
         }
 
+    // Add Executor metrics verification.
+    @Override
+    @Test(timeout = 300000) // timeout after five minutes
+    public void shouldUseDefaultExecutor()
+        {
+        Utils.assertWithFailureAction(super::shouldUseDefaultExecutor, this::dumpExecutorCacheStates);
+
+        AbstractMetricsFunctionalTest metricsHelper = new AbstractMetricsFunctionalTest();
+        Map<String, String>           tags          = new LinkedHashMap<>();
+
+        try
+            {
+            Eventually.assertThat(invoking(metricsHelper).getCacheMetric(s_metrics_port, "Coherence.Executor.TasksCompletedCount", tags), CoreMatchers.is(greaterThan(4L)));
+            }
+        catch (Exception e)
+            {
+            fail("Get Executor metrics failed with exception: " + e);
+            }
+        }
+
     // ----- constants ------------------------------------------------------
 
     protected static final String EXTEND_CONFIG = "coherence-concurrent-client-config.xml";
 
+    protected static final String METRICS_ENABLED_PROPERTY = "coherence.metrics.http.enabled";
+
+    protected static int s_metrics_port = MetricsHttpHelper.DEFAULT_PROMETHEUS_METRICS_PORT;
+
     // ----- data members ---------------------------------------------------
 
     /**
@@ -113,6 +150,7 @@ public String getLabel()
                              LogOutput.to(CESJavaSingleClusterTests.class.getSimpleName(), "ComputeServer"),
                              RoleName.of(STORAGE_DISABLED_MEMBER_ROLE),
                              LocalStorage.disabled(),
+                             SystemProperty.of(METRICS_ENABLED_PROPERTY, true),
                              SystemProperty.of(EXTEND_ENABLED_PROPERTY, false),
                              SystemProperty.of(EXECUTOR_LOGGING_PROPERTY, true))
                     .include(PROXY_MEMBER_COUNT,

prj/test/functional/metrics/src/main/java/metrics/AbstractMetricsFunctionalTest.java

@@ -32,6 +32,13 @@ public class AbstractMetricsFunctionalTest extends AbstractFunctionalTest
     {
     // ----- constructors ---------------------------------------------------
 
+    /**
+     * Default constructor
+     */
+    public AbstractMetricsFunctionalTest()
+        {
+        }
+
     /**
      * Constructor that initializes cluster member configuration file.
      *