Prometheus and Grafana

import {
  monitorEventLoopDelay,
  performance,
} from 'node:perf_hooks';

const sleep = (ms) =>
  new Promise((resolve) => setTimeout(resolve, ms));

function blockMainThread(durationMs) {
  const startedAt = performance.now();
  let iterations = 0;

  // Намеренная блокировка для учебного сценария. В production так делать нельзя.
  while (performance.now() - startedAt < durationMs) {
    iterations += Math.sqrt((iterations % 10_000) + 1);
  }

  return Math.round(iterations);
}

async function observabilitySignals(emit) {
  const histogram = monitorEventLoopDelay({ resolution: 10 });
  histogram.enable();
  const eluBefore = performance.eventLoopUtilization();
  const memoryBefore = process.memoryUsage();

  emit(
    'metrics',
    'sample',
    `До нагрузки: RSS=${Math.round(memoryBefore.rss / 1024 / 1024)} MB, heapUsed=${Math.round(
      memoryBefore.heapUsed / 1024 / 1024,
    )} MB`,
  );
  emit(
    'prometheus',
    'info',
    'Prometheus получает эти process/runtime/memory-lab ряды через GET /api/metrics',
  );

  // Даём monitorEventLoopDelay установить свой sampling timer до блокировки.
  await sleep(35);
  emit(
    'event-loop',
    'warning',
    'Создаём короткую контролируемую блокировку, чтобы метрика delay получила сигнал',
  );
  blockMainThread(140);
  await sleep(35);

  const elu = performance.eventLoopUtilization(eluBefore);
  const p95Ms = Number.isFinite(histogram.percentile(95))
    ? histogram.percentile(95) / 1e6
    : 0;
  const maxMs = Number.isFinite(histogram.max) ? histogram.max / 1e6 : 0;
  histogram.disable();

  emit(
    'metrics',
    'result',
    `Event Loop: p95 delay=${p95Ms.toFixed(1)} мс, max=${maxMs.toFixed(
      1,
    )} мс, ELU=${(elu.utilization * 100).toFixed(1)}%`,
  );
  emit(
    'grafana',
    'result',
    'Grafana не измеряет процесс сама: она строит панели по временным рядам, которые собрал Prometheus',
  );
}