{"version":3,"file":"TracerMetrics.js","sourceRoot":"","sources":["../../src/TracerMetrics.ts"],"names":[],"mappings":"AAUA,OAAO,EAAE,gBAAgB,EAAE,MAAM,WAAW,CAAC;AAC7C,OAAO,EACL,4BAA4B,EAC5B,8BAA8B,EAC9B,yBAAyB,EACzB,4BAA4B,GAC7B,MAAM,WAAW,CAAC;AAEnB;;;GAGG;AACH,MAAM,OAAO,aAAa;IACP,YAAY,CAAU;IACtB,SAAS,CAAgB;IAE1C,YAAY,KAAY;QACtB,IAAI,CAAC,YAAY,GAAG,KAAK,CAAC,aAAa,CAAC,4BAA4B,EAAE;YACpE,IAAI,EAAE,QAAQ;YACd,WAAW,EAAE,8BAA8B;SAC5C,CAAC,CAAC;QAEH,IAAI,CAAC,SAAS,GAAG,KAAK,CAAC,mBAAmB,CAAC,yBAAyB,EAAE;YACpE,IAAI,EAAE,QAAQ;YACd,WAAW,EAAE,qCAAqC;SACnD,CAAC,CAAC;IACL,CAAC;IAED,SAAS,CACP,aAAsC,EACtC,gBAAkC;QAElC,MAAM,mBAAmB,GAAG,wBAAwB,CAAC,gBAAgB,CAAC,CAAC;QACvE,IAAI,CAAC,YAAY,CAAC,GAAG,CAAC,CAAC,EAAE;YACvB,CAAC,4BAA4B,CAAC,EAAE,YAAY,CAAC,aAAa,CAAC;YAC3D,CAAC,8BAA8B,CAAC,EAAE,mBAAmB;SACtD,CAAC,CAAC;QAEH,IAAI,gBAAgB,KAAK,gBAAgB,CAAC,UAAU,EAAE;YACpD,OAAO,GAAG,EAAE,GAAE,CAAC,CAAC;SACjB;QAED,MAAM,kBAAkB,GAAG;YACzB,CAAC,8BAA8B,CAAC,EAAE,mBAAmB;SACtD,CAAC;QACF,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,CAAC,EAAE,kBAAkB,CAAC,CAAC;QAC1C,OAAO,GAAG,EAAE;YACV,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,kBAAkB,CAAC,CAAC;QAC7C,CAAC,CAAC;IACJ,CAAC;CACF;AAED,SAAS,YAAY,CAAC,iBAA0C;IAC9D,IAAI,CAAC,iBAAiB,EAAE;QACtB,OAAO,MAAM,CAAC;KACf;IACD,IAAI,iBAAiB,CAAC,QAAQ,EAAE;QAC9B,OAAO,QAAQ,CAAC;KACjB;IACD,OAAO,OAAO,CAAC;AACjB,CAAC;AAED,SAAS,wBAAwB,CAAC,QAA0B;IAC1D,QAAQ,QAAQ,EAAE;QAChB,KAAK,gBAAgB,CAAC,kBAAkB;YACtC,OAAO,mBAAmB,CAAC;QAC7B,KAAK,gBAAgB,CAAC,MAAM;YAC1B,OAAO,aAAa,CAAC;QACvB,KAAK,gBAAgB,CAAC,UAAU;YAC9B,OAAO,MAAM,CAAC;KACjB;AACH,CAAC","sourcesContent":["/*\n * Copyright The OpenTelemetry Authors\n * SPDX-License-Identifier: Apache-2.0\n */\nimport type {\n  Counter,\n  Meter,\n  SpanContext,\n  UpDownCounter,\n} from '@opentelemetry/api';\nimport { SamplingDecision } from './Sampler';\nimport {\n  ATTR_OTEL_SPAN_PARENT_ORIGIN,\n  ATTR_OTEL_SPAN_SAMPLING_RESULT,\n  METRIC_OTEL_SDK_SPAN_LIVE,\n  METRIC_OTEL_SDK_SPAN_STARTED,\n} from './semconv';\n\n/**\n * Generates `otel.sdk.span.*` metrics.\n * https://opentelemetry.io/docs/specs/semconv/otel/sdk-metrics/#span-metrics\n */\nexport class TracerMetrics {\n  private readonly startedSpans: Counter;\n  private readonly liveSpans: UpDownCounter;\n\n  constructor(meter: Meter) {\n    this.startedSpans = meter.createCounter(METRIC_OTEL_SDK_SPAN_STARTED, {\n      unit: '{span}',\n      description: 'The number of created spans.',\n    });\n\n    this.liveSpans = meter.createUpDownCounter(METRIC_OTEL_SDK_SPAN_LIVE, {\n      unit: '{span}',\n      description: 'The number of currently live spans.',\n    });\n  }\n\n  startSpan(\n    parentSpanCtx: SpanContext | undefined,\n    samplingDecision: SamplingDecision\n  ): () => void {\n    const samplingDecisionStr = samplingDecisionToString(samplingDecision);\n    this.startedSpans.add(1, {\n      [ATTR_OTEL_SPAN_PARENT_ORIGIN]: parentOrigin(parentSpanCtx),\n      [ATTR_OTEL_SPAN_SAMPLING_RESULT]: samplingDecisionStr,\n    });\n\n    if (samplingDecision === SamplingDecision.NOT_RECORD) {\n      return () => {};\n    }\n\n    const liveSpanAttributes = {\n      [ATTR_OTEL_SPAN_SAMPLING_RESULT]: samplingDecisionStr,\n    };\n    this.liveSpans.add(1, liveSpanAttributes);\n    return () => {\n      this.liveSpans.add(-1, liveSpanAttributes);\n    };\n  }\n}\n\nfunction parentOrigin(parentSpanContext: SpanContext | undefined): string {\n  if (!parentSpanContext) {\n    return 'none';\n  }\n  if (parentSpanContext.isRemote) {\n    return 'remote';\n  }\n  return 'local';\n}\n\nfunction samplingDecisionToString(decision: SamplingDecision): string {\n  switch (decision) {\n    case SamplingDecision.RECORD_AND_SAMPLED:\n      return 'RECORD_AND_SAMPLE';\n    case SamplingDecision.RECORD:\n      return 'RECORD_ONLY';\n    case SamplingDecision.NOT_RECORD:\n      return 'DROP';\n  }\n}\n"]}