147
taskQueueType enumspb.TaskQueueType,
148
operation string,
150
>
nsName := h.namespaceName(namespace.ID(namespaceID))
151
>
partition := tqid.UnsafePartitionFromProto(taskQueue, namespaceID, taskQueueType)
152
>
return metrics.GetPerTaskQueuePartitionIDScope(
153
>
h.metricsHandler.WithTags(metrics.OperationTag(operation)),
154
>
nsName.String(),
155
>
partition,
156
>
h.config.BreakdownMetricsByTaskQueue(nsName.String(), partition.TaskQueue().Name(), partition.TaskType()),
157
>
h.config.BreakdownMetricsByPartition(nsName.String(), partition.TaskQueue().Name(), partition.TaskType()),
158
>
)
159
>
}
160
161
// recordNexusTaskRequest emits the nexus_task_requests metric with namespace,