ObservabilityInstance

interface ObservabilityInstance {
  startActiveSpan(
    name: string,
    attributes: Record<string, any>,
    fn: (span: Span) => void,
  ): any

  getHistogram(
    name: string,
    options: MetricOptions,
  ): (value: number, attributes?: Record<string, any>) => void

  getIncrementCounter(
    name: string,
    options: MetricOptions,
  ): (value: number, attributes?: Record<string, any>) => void

  processTelemetryAttributes(data: any): any

  shutdown(): Promise<void>
}

telemetry.startActiveSpan('cache.lookup', { 'cache.key': 'user:42' }, (span) => {
  // ...
  span.end()
})

const recordDuration = telemetry.getHistogram('cache.lookup.duration', {
  description: 'Cache lookup duration',
  unit: 'ms',
})

recordDuration(12, { 'cache.hit': true })

const incRetry = telemetry.getIncrementCounter('upstream.retry.count', {
  description: 'Upstream retries',
})

incRetry(1, { upstream: 'github' })

const cleaned = telemetry.processTelemetryAttributes({
  'user.email': 'jane@acme.com',
})

process.on('SIGTERM', async () => {
  await telemetry.shutdown()
  process.exit(0)
})