diff --git a/server/queues/processors/BacklinksProcessor.ts b/server/queues/processors/BacklinksProcessor.ts index 2626f65d8..c4c3c4d45 100644 --- a/server/queues/processors/BacklinksProcessor.ts +++ b/server/queues/processors/BacklinksProcessor.ts @@ -6,7 +6,9 @@ import parseDocumentIds from "@server/utils/parseDocumentIds"; import slugify from "@server/utils/slugify"; import BaseProcessor from "./BaseProcessor"; -@APM.trace() +@APM.trace({ + spanName: "processor", +}) export default class BacklinksProcessor extends BaseProcessor { static applicableEvents: Event["name"][] = [ "documents.publish", diff --git a/server/queues/processors/DebounceProcessor.ts b/server/queues/processors/DebounceProcessor.ts index 3f6d9d42e..362ca908b 100644 --- a/server/queues/processors/DebounceProcessor.ts +++ b/server/queues/processors/DebounceProcessor.ts @@ -4,7 +4,9 @@ import { Event } from "@server/types"; import { globalEventQueue } from ".."; import BaseProcessor from "./BaseProcessor"; -@APM.trace() +@APM.trace({ + spanName: "processor", +}) export default class DebounceProcessor extends BaseProcessor { static applicableEvents: Event["name"][] = [ "documents.update", diff --git a/server/queues/processors/NotificationsProcessor.ts b/server/queues/processors/NotificationsProcessor.ts index 101b20618..30a19699b 100644 --- a/server/queues/processors/NotificationsProcessor.ts +++ b/server/queues/processors/NotificationsProcessor.ts @@ -19,7 +19,9 @@ import { } from "@server/types"; import BaseProcessor from "./BaseProcessor"; -@APM.trace() +@APM.trace({ + spanName: "processor", +}) export default class NotificationsProcessor extends BaseProcessor { static applicableEvents: Event["name"][] = [ "documents.publish", diff --git a/server/queues/processors/RevisionsProcessor.ts b/server/queues/processors/RevisionsProcessor.ts index 856383b8d..7fe1e3551 100644 --- a/server/queues/processors/RevisionsProcessor.ts +++ b/server/queues/processors/RevisionsProcessor.ts @@ -5,7 +5,9 @@ import { Revision, Document, User } from "@server/models"; import { DocumentEvent, RevisionEvent, Event } from "@server/types"; import BaseProcessor from "./BaseProcessor"; -@APM.trace() +@APM.trace({ + spanName: "processor", +}) export default class RevisionsProcessor extends BaseProcessor { static applicableEvents: Event["name"][] = ["documents.update.debounced"]; diff --git a/server/queues/processors/SlackProcessor.ts b/server/queues/processors/SlackProcessor.ts index a5d81f540..36808a575 100644 --- a/server/queues/processors/SlackProcessor.ts +++ b/server/queues/processors/SlackProcessor.ts @@ -11,7 +11,9 @@ import { } from "@server/types"; import BaseProcessor from "./BaseProcessor"; -@APM.trace() +@APM.trace({ + spanName: "processor", +}) export default class SlackProcessor extends BaseProcessor { static applicableEvents: Event["name"][] = [ "documents.publish", diff --git a/server/queues/processors/WebsocketsProcessor.ts b/server/queues/processors/WebsocketsProcessor.ts index 16807e31d..1584ce7c7 100644 --- a/server/queues/processors/WebsocketsProcessor.ts +++ b/server/queues/processors/WebsocketsProcessor.ts @@ -19,7 +19,9 @@ import { } from "@server/presenters"; import { Event } from "../../types"; -@APM.trace() +@APM.trace({ + spanName: "processor", +}) export default class WebsocketsProcessor { async perform(event: Event, socketio: Server) { switch (event.name) { diff --git a/server/queues/tasks/CleanupDeletedDocumentsTask.ts b/server/queues/tasks/CleanupDeletedDocumentsTask.ts index ed54e8f79..a8867beb9 100644 --- a/server/queues/tasks/CleanupDeletedDocumentsTask.ts +++ b/server/queues/tasks/CleanupDeletedDocumentsTask.ts @@ -10,7 +10,9 @@ type Props = { limit: number; }; -@APM.trace() +@APM.trace({ + spanName: "task", +}) export default class CleanupDeletedDocumentsTask extends BaseTask { public async perform({ limit }: Props) { Logger.info( diff --git a/server/queues/tasks/CleanupDeletedTeamsTask.ts b/server/queues/tasks/CleanupDeletedTeamsTask.ts index d874a31bb..b8c350746 100644 --- a/server/queues/tasks/CleanupDeletedTeamsTask.ts +++ b/server/queues/tasks/CleanupDeletedTeamsTask.ts @@ -10,7 +10,9 @@ type Props = { limit: number; }; -@APM.trace() +@APM.trace({ + spanName: "task", +}) export default class CleanupDeletedTeamsTask extends BaseTask { public async perform({ limit }: Props) { Logger.info( diff --git a/server/queues/tasks/CleanupExpiredFileOperationsTask.ts b/server/queues/tasks/CleanupExpiredFileOperationsTask.ts index 7544f22e8..7cc3b7b0e 100644 --- a/server/queues/tasks/CleanupExpiredFileOperationsTask.ts +++ b/server/queues/tasks/CleanupExpiredFileOperationsTask.ts @@ -9,7 +9,9 @@ type Props = { limit: number; }; -@APM.trace() +@APM.trace({ + spanName: "task", +}) export default class CleanupExpiredFileOperationsTask extends BaseTask { public async perform({ limit }: Props) { Logger.info("task", `Expiring export file operations older than 30 days…`); diff --git a/server/queues/tasks/EmailTask.ts b/server/queues/tasks/EmailTask.ts index 3384a7966..c089ce64c 100644 --- a/server/queues/tasks/EmailTask.ts +++ b/server/queues/tasks/EmailTask.ts @@ -7,7 +7,9 @@ type Props = { props: Record; }; -@APM.trace() +@APM.trace({ + spanName: "task", +}) export default class EmailTask extends BaseTask { public async perform({ templateName, props }: Props) { const EmailClass = emails[templateName];