refactor: Update ingestor replica count based on configuration

This commit updates the ingestor replica count in the HelmChart/Public/oneuptime/templates/ingestor.yaml file based on the configuration. If the `$.Values.deployment.ingestor.replicaCount` value is provided, it sets the replicas to that value. Otherwise, it falls back to `$.Values.deployment.replicaCount`. This change ensures that the ingestor replica count is correctly configured, improving the scalability and performance of the application.
OneUptime · Jul 5, 2024 · c617e49 · c617e49
1 parent de7d06e
commit c617e49
Show file tree

Hide file tree

Showing 3 changed files with 31 additions and 15 deletions.
diff --git a/HelmChart/Public/oneuptime/templates/ingestor.yaml b/HelmChart/Public/oneuptime/templates/ingestor.yaml
@@ -15,7 +15,11 @@ spec:
   selector:
     matchLabels:
       app: {{ printf "%s-%s" $.Release.Name "ingestor"  }}
+  {{- if $.Values.deployment.ingestor.replicaCount }}
+  replicas: {{ $.Values.deployment.ingestor.replicaCount }}
+  {{- else }}
   replicas: {{ $.Values.deployment.replicaCount }}
+  {{- end }}
   template:
     metadata:
       labels:

diff --git a/HelmChart/Public/oneuptime/values.yaml b/HelmChart/Public/oneuptime/values.yaml
@@ -17,6 +17,8 @@ fluentdHost:
 
 deployment: 
   replicaCount: 1
+  ingestor:
+    replicaCount: 
 
 metalLb: 
   enabled: false

diff --git a/Ingestor/API/Monitor.ts b/Ingestor/API/Monitor.ts
@@ -275,6 +275,8 @@ router.post(
 
       // update the lastMonitoredAt field of the monitors
 
+      const updatePromises: Array<Promise<void>> = [];
+
       for (const monitorProbe of monitorProbes) {
         if (!monitorProbe.monitor) {
           continue;
@@ -293,18 +295,22 @@ router.post(
           logger.error(err);
         }
 
-        await MonitorProbeService.updateOneById({
-          id: monitorProbe.id!,
-          data: {
-            lastPingAt: OneUptimeDate.getCurrentDate(),
-            nextPingAt: nextPing,
-          },
-          props: {
-            isRoot: true,
-          },
-        });
+        updatePromises.push(
+          MonitorProbeService.updateOneById({
+            id: monitorProbe.id!,
+            data: {
+              lastPingAt: OneUptimeDate.getCurrentDate(),
+              nextPingAt: nextPing,
+            },
+            props: {
+              isRoot: true,
+            },
+          }),
+        );
       }
 
+      await Promise.all(updatePromises);
+
       // if (mutex) {
       //   try {
       //     await Semaphore.release(mutex);
@@ -326,15 +332,19 @@ router.post(
 
       // check if the monitor needs secrets to be filled.
 
-      const monitorsWithSecretPopulated: Array<Monitor> = [];
+      let monitorsWithSecretPopulated: Array<Monitor> = [];
+      const monitorWithSecretsPopulatePromises: Array<Promise<Monitor>> = [];
 
       for (const monitor of monitors) {
-        const monitorWithSecrets: Monitor =
-          await MonitorUtil.populateSecrets(monitor);
-
-        monitorsWithSecretPopulated.push(monitorWithSecrets);
+        monitorWithSecretsPopulatePromises.push(
+          MonitorUtil.populateSecrets(monitor),
+        );
       }
 
+      monitorsWithSecretPopulated = await Promise.all(
+        monitorWithSecretsPopulatePromises,
+      );
+
       logger.debug("Populated secrets");
       logger.debug(monitorsWithSecretPopulated);