tmp

cryostatio · Apr 24, 2023 · 763b3d1 · 763b3d1
1 parent 043ea78
commit 763b3d1
Show file tree

Hide file tree

Showing 3 changed files with 21 additions and 4 deletions.
diff --git a/src/main/java/io/cryostat/MainModule.java b/src/main/java/io/cryostat/MainModule.java
@@ -194,7 +194,15 @@ public static Function<String, UUID> provideUuidToString() {
 
     @Provides
     @Singleton
-    public static VerticleDeployer provideVerticleDeployer(Vertx vertx, Logger logger) {
-        return new VerticleDeployer(vertx, logger);
+    @Named(Variables.VERTX_POOL_SIZE)
+    public static int provideVertxPoolSize(Environment env) {
+        return Math.max(1, Integer.parseInt(env.getEnv(Variables.VERTX_POOL_SIZE, "20")));
+    }
+
+    @Provides
+    @Singleton
+    public static VerticleDeployer provideVerticleDeployer(
+            Vertx vertx, @Named(Variables.VERTX_POOL_SIZE) int poolSize, Logger logger) {
+        return new VerticleDeployer(vertx, poolSize, logger);
     }
 }
diff --git a/src/main/java/io/cryostat/VerticleDeployer.java b/src/main/java/io/cryostat/VerticleDeployer.java
@@ -48,20 +48,28 @@
 public class VerticleDeployer {
 
     private final Vertx vertx;
+    private final int poolSize;
     private final Logger logger;
 
     @SuppressFBWarnings(
             value = "EI_EXPOSE_REP2",
             justification = "vertx is externally mutable and that's fine")
-    public VerticleDeployer(Vertx vertx, Logger logger) {
+    public VerticleDeployer(Vertx vertx, int poolSize, Logger logger) {
         this.vertx = vertx;
+        this.poolSize = poolSize;
         this.logger = logger;
     }
 
     public Future deploy(Verticle verticle, boolean worker) {
         String name = verticle.getClass().getName();
         logger.info("Deploying {} Verticle", name);
-        return vertx.deployVerticle(verticle, new DeploymentOptions().setWorker(worker))
+        DeploymentOptions deploymentOptions = new DeploymentOptions();
+        deploymentOptions.setWorker(worker);
+        if (deploymentOptions.isWorker()) {
+            deploymentOptions.setWorkerPoolName(verticle.getClass().getSimpleName() + "-worker");
+            deploymentOptions.setWorkerPoolSize(poolSize);
+        }
+        return vertx.deployVerticle(verticle, deploymentOptions)
                 .onSuccess(id -> logger.info("Deployed {} Verticle [{}]", name, id))
                 .onFailure(
                         t -> {

diff --git a/src/main/java/io/cryostat/configuration/Variables.java b/src/main/java/io/cryostat/configuration/Variables.java
@@ -70,6 +70,7 @@ private Variables() {}
     public static final String DISABLE_BUILTIN_DISCOVERY = "CRYOSTAT_DISABLE_BUILTIN_DISCOVERY";
     public static final String DISCOVERY_PING_PERIOD_MS = "CRYOSTAT_DISCOVERY_PING_PERIOD";
     public static final String K8S_NAMESPACES = "CRYOSTAT_K8S_NAMESPACES";
+    public static final String VERTX_POOL_SIZE = "CRYOSTAT_VERTX_POOL_SIZE";
 
     // webserver configuration
     public static final String WEBSERVER_HOST = "CRYOSTAT_WEB_HOST";