diff --git a/FluentIngest/Index.ts b/FluentIngest/Index.ts index 9d25283563..e2792bb6a9 100644 --- a/FluentIngest/Index.ts +++ b/FluentIngest/Index.ts @@ -11,6 +11,7 @@ import Realtime from "Common/Server/Utils/Realtime"; import App from "Common/Server/Utils/StartServer"; import Telemetry from "Common/Server/Utils/Telemetry"; import "./Jobs/FluentIngest/ProcessFluentIngest"; +import { FLUENT_INGEST_CONCURRENCY } from "./Config"; const app: ExpressApplication = Express.getExpressApp(); @@ -35,6 +36,8 @@ const init: PromiseVoidFunction = async (): Promise => { serviceName: APP_NAME, }); + logger.info(`FluentIngest Service - Queue concurrency: ${FLUENT_INGEST_CONCURRENCY}`); + // init the app await App.init({ appName: APP_NAME, diff --git a/IncomingRequestIngest/Index.ts b/IncomingRequestIngest/Index.ts index 170b52e844..c6d48f538a 100644 --- a/IncomingRequestIngest/Index.ts +++ b/IncomingRequestIngest/Index.ts @@ -11,6 +11,7 @@ import Realtime from "Common/Server/Utils/Realtime"; import App from "Common/Server/Utils/StartServer"; import Telemetry from "Common/Server/Utils/Telemetry"; import "./Jobs/IncomingRequestIngest/ProcessIncomingRequestIngest"; +import { INCOMING_REQUEST_INGEST_CONCURRENCY } from "./Config"; import "ejs"; const app: ExpressApplication = Express.getExpressApp(); @@ -36,6 +37,8 @@ const init: PromiseVoidFunction = async (): Promise => { serviceName: APP_NAME, }); + logger.info(`IncomingRequestIngest Service - Queue concurrency: ${INCOMING_REQUEST_INGEST_CONCURRENCY}`); + // init the app await App.init({ appName: APP_NAME, diff --git a/OpenTelemetryIngest/Index.ts b/OpenTelemetryIngest/Index.ts index 868639484c..82e75d5499 100644 --- a/OpenTelemetryIngest/Index.ts +++ b/OpenTelemetryIngest/Index.ts @@ -11,6 +11,7 @@ import Realtime from "Common/Server/Utils/Realtime"; import App from "Common/Server/Utils/StartServer"; import Telemetry from "Common/Server/Utils/Telemetry"; import "./Jobs/TelemetryIngest/ProcessTelemetry"; +import { OPEN_TELEMETRY_INGEST_CONCURRENCY } from "./Config"; import "ejs"; const app: ExpressApplication = Express.getExpressApp(); @@ -36,6 +37,8 @@ const init: PromiseVoidFunction = async (): Promise => { serviceName: APP_NAME, }); + logger.info(`OpenTelemetryIngest Service - Queue concurrency: ${OPEN_TELEMETRY_INGEST_CONCURRENCY}`); + // init the app await App.init({ appName: APP_NAME, diff --git a/Probe/Index.ts b/Probe/Index.ts index 8a7bc99f20..0094553b70 100644 --- a/Probe/Index.ts +++ b/Probe/Index.ts @@ -1,4 +1,4 @@ -import { PORT } from "./Config"; +import { PORT, PROBE_MONITORING_WORKERS, PROBE_MONITOR_FETCH_LIMIT, PROBE_SYNTHETIC_MONITOR_SCRIPT_TIMEOUT_IN_MS, PROBE_CUSTOM_CODE_MONITOR_SCRIPT_TIMEOUT_IN_MS, PROBE_MONITOR_RETRY_LIMIT } from "./Config"; import AliveJob from "./Jobs/Alive"; import FetchMonitorList from "./Jobs/Monitor/FetchList"; import FetchMonitorTestList from "./Jobs/Monitor/FetchMonitorTest"; @@ -20,6 +20,8 @@ const init: PromiseVoidFunction = async (): Promise => { serviceName: APP_NAME, }); + logger.info(`Probe Service - Monitoring workers: ${PROBE_MONITORING_WORKERS}, Monitor fetch limit: ${PROBE_MONITOR_FETCH_LIMIT}, Script timeout: ${PROBE_SYNTHETIC_MONITOR_SCRIPT_TIMEOUT_IN_MS}ms / ${PROBE_CUSTOM_CODE_MONITOR_SCRIPT_TIMEOUT_IN_MS}ms, Retry limit: ${PROBE_MONITOR_RETRY_LIMIT}`); + // init the app await App.init({ appName: APP_NAME, diff --git a/ProbeIngest/Index.ts b/ProbeIngest/Index.ts index 1ed8e6fcd6..11c4b3a516 100644 --- a/ProbeIngest/Index.ts +++ b/ProbeIngest/Index.ts @@ -13,6 +13,7 @@ import Realtime from "Common/Server/Utils/Realtime"; import App from "Common/Server/Utils/StartServer"; import Telemetry from "Common/Server/Utils/Telemetry"; import "./Jobs/ProbeIngest/ProcessProbeIngest"; +import { PROBE_INGEST_CONCURRENCY } from "./Config"; import "ejs"; const app: ExpressApplication = Express.getExpressApp(); @@ -41,6 +42,8 @@ const init: PromiseVoidFunction = async (): Promise => { serviceName: APP_NAME, }); + logger.info(`ProbeIngest Service - Queue concurrency: ${PROBE_INGEST_CONCURRENCY}`); + // init the app await App.init({ appName: APP_NAME, diff --git a/ServerMonitorIngest/Index.ts b/ServerMonitorIngest/Index.ts index 71135db1f5..5fe647a976 100644 --- a/ServerMonitorIngest/Index.ts +++ b/ServerMonitorIngest/Index.ts @@ -11,6 +11,7 @@ import Realtime from "Common/Server/Utils/Realtime"; import App from "Common/Server/Utils/StartServer"; import Telemetry from "Common/Server/Utils/Telemetry"; import "./Jobs/ServerMonitorIngest/ProcessServerMonitorIngest"; +import { SERVER_MONITOR_INGEST_CONCURRENCY } from "./Config"; const app: ExpressApplication = Express.getExpressApp(); @@ -35,6 +36,8 @@ const init: PromiseVoidFunction = async (): Promise => { serviceName: APP_NAME, }); + logger.info(`ServerMonitorIngest Service - Queue concurrency: ${SERVER_MONITOR_INGEST_CONCURRENCY}`); + // init the app await App.init({ appName: APP_NAME, diff --git a/Worker/Index.ts b/Worker/Index.ts index 1ca5cba31f..48e745e46f 100644 --- a/Worker/Index.ts +++ b/Worker/Index.ts @@ -8,6 +8,7 @@ import Realtime from "Common/Server/Utils/Realtime"; import PostgresAppInstance from "Common/Server/Infrastructure/PostgresDatabase"; import Redis from "Common/Server/Infrastructure/Redis"; import { ClickhouseAppInstance } from "Common/Server/Infrastructure/ClickhouseDatabase"; +import { WORKER_CONCURRENCY } from "./Config"; import "ejs"; const APP_NAME: string = "worker"; @@ -23,6 +24,8 @@ const init: PromiseVoidFunction = async (): Promise => { logger.debug("Telemetry initialized"); + logger.info(`Worker Service - Queue concurrency: ${WORKER_CONCURRENCY}`); + const statusCheck: PromiseVoidFunction = async (): Promise => { // Check the status of infrastructure components return await InfrastructureStatus.checkStatusWithRetry({