github/oneuptime
1
1
Fork 0
mirror of https://github.com/OneUptime/oneuptime.git synced 2026-04-06 00:32:12 +02:00
Code Issues 193 Packages Projects Releases Wiki Activity

fix: format code for consistency in OtelIngest services

Browse Source
This commit is contained in:
Nawaz Dhandala
2025-10-16 14:22:09 +01:00
parent b76a75479d
commit 0ee9876de9
3 changed files with 7 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
OpenTelemetryIngest/API/OTelIngest.ts
View File

@@ -31,7 +31,7 @@ router.post(
res: ExpressResponse,
next: NextFunction,
): Promise<void> => {
return OtelTracesIngestService.ingestTraces(req, res, next);
return OtelTracesIngestService.ingestTraces(req, res, next);
},
);
@@ -44,7 +44,7 @@ router.post(
res: ExpressResponse,
next: NextFunction,
): Promise<void> => {
return OtelMetricsIngestService.ingestMetrics(req, res, next);
return OtelMetricsIngestService.ingestMetrics(req, res, next);
},
);
@@ -57,7 +57,7 @@ router.post(
res: ExpressResponse,
next: NextFunction,
): Promise<void> => {
return OtelLogsIngestService.ingestLogs(req, res, next);
return OtelLogsIngestService.ingestLogs(req, res, next);
},
);

8
OpenTelemetryIngest/Services/OtelLogsIngestService.ts
View File

@@ -26,9 +26,7 @@ import logger from "Common/Server/Utils/Logger";
import CaptureSpan from "Common/Server/Utils/Telemetry/CaptureSpan";
import LogsQueueService from "./Queue/LogsQueueService";
import OtelIngestBaseService from "./OtelIngestBaseService";
import {
OPEN_TELEMETRY_INGEST_LOG_FLUSH_BATCH_SIZE,
} from "../Config";
import { OPEN_TELEMETRY_INGEST_LOG_FLUSH_BATCH_SIZE } from "../Config";
export default class OtelLogsIngestService extends OtelIngestBaseService {
private static async flushLogsBuffer(
@@ -84,9 +82,7 @@ export default class OtelLogsIngestService extends OtelIngestBaseService {
}
@CaptureSpan()
public static async processLogsFromQueue(
req: ExpressRequest,
): Promise<void> {
public static async processLogsFromQueue(req: ExpressRequest): Promise<void> {
await this.processLogsAsync(req);
}

8
OpenTelemetryIngest/Services/OtelMetricsIngestService.ts
View File

@@ -29,9 +29,7 @@ import MetricType from "Common/Models/DatabaseModels/MetricType";
import TelemetryService from "Common/Models/DatabaseModels/TelemetryService";
import MetricsQueueService from "./Queue/MetricsQueueService";
import OtelIngestBaseService from "./OtelIngestBaseService";
import {
OPEN_TELEMETRY_INGEST_METRIC_FLUSH_BATCH_SIZE,
} from "../Config";
import { OPEN_TELEMETRY_INGEST_METRIC_FLUSH_BATCH_SIZE } from "../Config";
export default class OtelMetricsIngestService extends OtelIngestBaseService {
private static async flushMetricsBuffer(
@@ -94,9 +92,7 @@ export default class OtelMetricsIngestService extends OtelIngestBaseService {
}
@CaptureSpan()
private static async processMetricsAsync(
req: ExpressRequest,
): Promise<void> {
private static async processMetricsAsync(req: ExpressRequest): Promise<void> {
try {
const resourceMetrics: JSONArray = req.body[
"resourceMetrics"