diff --git a/javascript/sentry-conventions/src/op.ts b/javascript/sentry-conventions/src/op.ts index e1b764fc..f4af771e 100644 --- a/javascript/sentry-conventions/src/op.ts +++ b/javascript/sentry-conventions/src/op.ts @@ -180,6 +180,46 @@ export const MESSAGING_QUEUE_PROCESS_SPAN_OP = 'queue.process'; */ export const MESSAGING_QUEUE_SETTLE_SPAN_OP = 'queue.settle'; +/** + * Publishing a message to an arq queue. + */ +export const MESSAGING_QUEUE_SUBMIT_ARQ_SPAN_OP = 'queue.submit.arq'; + +/** + * Processing a message from an arq queue. + */ +export const MESSAGING_QUEUE_TASK_ARQ_SPAN_OP = 'queue.task.arq'; + +/** + * Publishing a message to a Celery broker. + */ +export const MESSAGING_QUEUE_SUBMIT_CELERY_SPAN_OP = 'queue.submit.celery'; + +/** + * Processing a message from a Celery queue. + */ +export const MESSAGING_QUEUE_TASK_CELERY_SPAN_OP = 'queue.task.celery'; + +/** + * Processing a message from a Dramatiq queue. + */ +export const MESSAGING_QUEUE_TASK_DRAMATIQ_SPAN_OP = 'queue.task.dramatiq'; + +/** + * Publishing a message to a Huey instance. + */ +export const MESSAGING_QUEUE_SUBMIT_HUEY_SPAN_OP = 'queue.submit.huey'; + +/** + * Processing a message from a Huey instance. + */ +export const MESSAGING_QUEUE_TASK_HUEY_SPAN_OP = 'queue.task.huey'; + +/** + * Processing a message from an RQ queue. + */ +export const MESSAGING_QUEUE_TASK_RQ_SPAN_OP = 'queue.task.rq'; + // Path: model/op/mobile.json // Name: mobile diff --git a/model/description/messaging.json b/model/description/messaging.json index 29059213..a600aa5c 100644 --- a/model/description/messaging.json +++ b/model/description/messaging.json @@ -4,7 +4,22 @@ { "name": "Queue", "brief": "Operations that represent working with message queues, including publishing, receiving, processing, and settling messages.", - "ops": ["queue", "queue.publish", "queue.create", "queue.receive", "queue.process", "queue.settle"], + "ops": [ + "queue", + "queue.publish", + "queue.create", + "queue.receive", + "queue.process", + "queue.settle", + "queue.submit.arq", + "queue.task.arq", + "queue.submit.celery", + "queue.task.celery", + "queue.task.dramatiq", + "queue.submit.huey", + "queue.task.huey", + "queue.task.rq" + ], "templates": ["{{messaging.destination.name}}"], "examples": ["order-events"] } diff --git a/model/op/messaging.json b/model/op/messaging.json index d2d8c1ca..50420c77 100644 --- a/model/op/messaging.json +++ b/model/op/messaging.json @@ -25,6 +25,38 @@ { "name": "queue.settle", "description": "Settling a message, e.g. acknowledging or rejecting it." + }, + { + "name": "queue.submit.arq", + "description": "Publishing a message to an arq queue." + }, + { + "name": "queue.task.arq", + "description": "Processing a message from an arq queue." + }, + { + "name": "queue.submit.celery", + "description": "Publishing a message to a Celery broker." + }, + { + "name": "queue.task.celery", + "description": "Processing a message from a Celery queue." + }, + { + "name": "queue.task.dramatiq", + "description": "Processing a message from a Dramatiq queue." + }, + { + "name": "queue.submit.huey", + "description": "Publishing a message to a Huey instance." + }, + { + "name": "queue.task.huey", + "description": "Processing a message from a Huey instance." + }, + { + "name": "queue.task.rq", + "description": "Processing a message from an RQ queue." } ] } diff --git a/rust/src/op.rs b/rust/src/op.rs index 7ae22d59..cd775fd9 100644 --- a/rust/src/op.rs +++ b/rust/src/op.rs @@ -140,6 +140,30 @@ pub const MESSAGING_QUEUE_PROCESS_SPAN_OP: &str = "queue.process"; /// Settling a message, e.g. acknowledging or rejecting it. pub const MESSAGING_QUEUE_SETTLE_SPAN_OP: &str = "queue.settle"; +/// Publishing a message to an arq queue. +pub const MESSAGING_QUEUE_SUBMIT_ARQ_SPAN_OP: &str = "queue.submit.arq"; + +/// Processing a message from an arq queue. +pub const MESSAGING_QUEUE_TASK_ARQ_SPAN_OP: &str = "queue.task.arq"; + +/// Publishing a message to a Celery broker. +pub const MESSAGING_QUEUE_SUBMIT_CELERY_SPAN_OP: &str = "queue.submit.celery"; + +/// Processing a message from a Celery queue. +pub const MESSAGING_QUEUE_TASK_CELERY_SPAN_OP: &str = "queue.task.celery"; + +/// Processing a message from a Dramatiq queue. +pub const MESSAGING_QUEUE_TASK_DRAMATIQ_SPAN_OP: &str = "queue.task.dramatiq"; + +/// Publishing a message to a Huey instance. +pub const MESSAGING_QUEUE_SUBMIT_HUEY_SPAN_OP: &str = "queue.submit.huey"; + +/// Processing a message from a Huey instance. +pub const MESSAGING_QUEUE_TASK_HUEY_SPAN_OP: &str = "queue.task.huey"; + +/// Processing a message from an RQ queue. +pub const MESSAGING_QUEUE_TASK_RQ_SPAN_OP: &str = "queue.task.rq"; + // Path: model/op/mobile.json // Name: mobile