161
// recordNexusTaskRequest emits the nexus_task_requests metric with namespace,
162
// operation, client_name, and is_internal tags.
163
>
func (h *Handler) recordNexusTaskRequest(ctx context.Context, namespaceID string, taskQueueKind enumspb.TaskQueueKind, operation string) {
handler.go
164
>
nsName := h.namespaceName(namespace.ID(namespaceID))
165
>
clientName, _ := headers.GetClientNameAndVersion(ctx)
166
>
isInternal := primitives.IsInternalTaskQueueKind(taskQueueKind)
167
>
metrics.NexusTaskRequests.With(h.metricsHandler).Record(1,
168
>
metrics.NamespaceTag(nsName.String()),
169
>
metrics.OperationTag(operation),
170
>
metrics.ClientNameTag(clientName),
171
>
metrics.IsInternalTag(isInternal),
172
>
)
173
>
}
174
175
// AddActivityTask - adds an activity task.