Scale by queue

TheEadie · Nov 23, 2024 · 95d2cce · 95d2cce
1 parent 2867a3e
commit 95d2cce
Showing 1 changed file with 31 additions and 2 deletions.
diff --git a/deployment/Worms.Hub.Infrastructure/src/ContainerApps/ReplayProcessor.cs b/deployment/Worms.Hub.Infrastructure/src/ContainerApps/ReplayProcessor.cs
@@ -1,3 +1,4 @@
+using System.Collections.Generic;
 using Pulumi;
 using Pulumi.AzureNative.App;
 using Pulumi.AzureNative.App.Inputs;
@@ -26,14 +27,42 @@ public static Job Config(
                 EnvironmentId = managedEnvironment.Id,
                 Configuration = new JobConfigurationArgs
                 {
-                    ManualTriggerConfig = new JobConfigurationManualTriggerConfigArgs
+                    EventTriggerConfig = new JobConfigurationEventTriggerConfigArgs
                     {
                         Parallelism = 1,
                         ReplicaCompletionCount = 1,
+                        Scale = new JobScaleArgs
+                        {
+                            MaxExecutions = 10,
+                            MinExecutions = 0,
+                            PollingInterval = 60,
+                            Rules = new[]
+                            {
+                                new JobScaleRuleArgs
+                                {
+                                    Auth = new[]
+                                    {
+                                        new ScaleRuleAuthArgs
+                                        {
+                                            SecretRef = "queue-connection",
+                                            TriggerParameter = "connection",
+                                        },
+                                    },
+                                    Metadata = new Dictionary<string, string>
+                                    {
+                                        {"accountName","wormstesttest"},
+                                        {"queueName","replays-to-process"},
+                                        {"queueLength","1"}
+                                    },
+                                    Name = "queue",
+                                    Type = "azure-queue",
+                                },
+                            },
+                        },
                     },
                     ReplicaRetryLimit = 10,
                     ReplicaTimeout = 3600,
-                    TriggerType = TriggerType.Manual,
+                    TriggerType = TriggerType.Event,
                     Secrets =
                     [
                         new SecretArgs