[DO NOT REVIEW] Stress test pubsub without docker

boms/geode-all-bom/src/test/resources/expected-pom.xml

@@ -205,7 +205,7 @@
       <dependency>
         <groupId>io.netty</groupId>
         <artifactId>netty-all</artifactId>
-        <version>4.1.59.Final</version>
+        <version>4.1.66.Final</version>
       </dependency>
       <dependency>
         <groupId>io.swagger</groupId>

buildSrc/build.gradle

@@ -35,7 +35,6 @@ dependencies {
   implementation('org.apache.commons:commons-lang3:3.12.0')
   implementation('org.apache.maven:maven-artifact:3.8.1')
   implementation('com.google.guava:guava:30.1.1-jre')
-  implementation('com.github.docker-java:docker-java:3.2.8')
   implementation('me.champeau.gradle:japicmp-gradle-plugin:0.2.9')
   implementation('junit:junit:4.13.2')
 

buildSrc/src/main/groovy/org/apache/geode/gradle/plugins/DependencyConstraints.groovy

@@ -115,7 +115,7 @@ class DependencyConstraints implements Plugin<Project> {
         api(group: 'io.github.resilience4j', name: 'resilience4j-retry', version: '1.7.1')
         api(group: 'io.lettuce', name: 'lettuce-core', version: '6.1.3.RELEASE')
         api(group: 'io.micrometer', name: 'micrometer-core', version: get('micrometer.version'))
-        api(group: 'io.netty', name: 'netty-all', version: '4.1.59.Final')
+        api(group: 'io.netty', name: 'netty-all', version: '4.1.66.Final')
         api(group: 'io.swagger', name: 'swagger-annotations', version: '1.6.2')
         api(group: 'it.unimi.dsi', name: 'fastutil', version: get('fastutil.version'))
         api(group: 'javax.annotation', name: 'javax.annotation-api', version: '1.3.2')

buildSrc/src/main/groovy/org/apache/geode/gradle/testing/isolation/IsolatedTestPlugin.groovy

@@ -0,0 +1,87 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more contributor license
+ * agreements. See the NOTICE file distributed with this work for additional information regarding
+ * copyright ownership. The ASF licenses this file to You 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 org.apache.geode.gradle.testing.isolation
+
+import org.apache.geode.gradle.testing.Executers
+import org.apache.geode.gradle.testing.Workers
+import org.gradle.api.Plugin
+import org.gradle.api.Project
+import org.gradle.api.tasks.testing.Test
+import org.gradle.internal.remote.MessagingServer
+import org.gradle.process.internal.worker.WorkerProcessFactory
+
+import javax.inject.Inject
+
+/**
+ * Configures isolated test tasks to launch each test worker with a distinct range of available
+ * ports. A test task is an isolated test task if it has an {@code isolatedTest} property.
+ */
+class IsolatedTestPlugin implements Plugin<Project> {
+    static def gradleWorkerProcessFactory
+    static def gradleMessagingServer
+    static def portRangeWorkerProcessFactory
+
+    @Inject
+    IsolatedTestPlugin(MessagingServer gradleMessagingServer,
+                       WorkerProcessFactory gradleWorkerProcessFactory) {
+        initializeGradleWorkerProcessFactory(gradleWorkerProcessFactory)
+        initializeGradleMessagingServer(gradleMessagingServer)
+    }
+
+    @Override
+    void apply(Project project) {
+        initializePortRangeWorkerProcessFactory(project.gradle.startParameter.maxWorkerCount)
+
+        def usePortRangeTestWorker = {
+            if (!it.hasProperty('isolatedTest')) {
+                return
+            }
+            it.doFirst {
+                testExecuter = Executers.withFactory(it, portRangeWorkerProcessFactory)
+            }
+        }
+
+        project.tasks.withType(Test).each(usePortRangeTestWorker)
+        project.tasks.whenTaskAdded() {
+            if (it instanceof Test) {
+                it.configure(usePortRangeTestWorker)
+            }
+        }
+    }
+
+    synchronized static initializePortRangeWorkerProcessFactory(int partitionCount) {
+        if (portRangeWorkerProcessFactory != null) {
+            return
+        }
+        portRangeWorkerProcessFactory = Workers.createWorkerProcessFactory(
+            gradleWorkerProcessFactory,
+            new PortRangeProcessLauncher(partitionCount, new WorkingDirectoryIsolator()),
+            gradleMessagingServer
+        )
+    }
+
+    synchronized static initializeGradleMessagingServer(server) {
+        if (!gradleMessagingServer) {
+            gradleMessagingServer = server
+        }
+    }
+
+    synchronized static void initializeGradleWorkerProcessFactory(factory) {
+        if (!gradleWorkerProcessFactory) {
+            gradleWorkerProcessFactory = factory
+        }
+    }
+}