Function enqueue

apps/sim/lib/monitoring/metrics.ts:94–117

(
  MetricName: string,
  Value: number,
  Unit: StandardUnit,
  labels: Record<string, string | undefined>
)

}

function enqueue(
  MetricName: string,
  Value: number,
  Unit: StandardUnit,
  labels: Record<string, string | undefined>
): void {
  if (!ENABLED) return
  buffer.push({
    MetricName,
    Value,
    Unit,
    Timestamp: new Date(),
    Dimensions: buildDimensions(labels),
  })
  if (buffer.length > MAX_BUFFER) {
    // Flushing has stalled (CloudWatch slow/erroring) — bound memory by dropping
    // the oldest points instead of growing without limit.
    const overflow = buffer.length - MAX_BUFFER
    buffer.splice(0, overflow)
    dropped += overflow
  }
  ensureBackground()
  if (buffer.length >= FLUSH_THRESHOLD) void flushHostedKeyMetrics()
}

/** Drain the buffer to CloudWatch. Safe to call repeatedly; await before exit. */
export async function flushHostedKeyMetrics(): Promise<void> {