Function snapshot

apps/cloud/src/observability/memory-metrics.ts:122–153

(now: number, maxQueueSize: number)

});

const snapshot = (now: number, maxQueueSize: number) => {
  let oldestConnectionAgeMs = 0;
  let stalledConnections = 0;
  let ageBuckets = emptyAgeBuckets();
  const colos = new Set<string>();
  const scriptVersions = new Set<string>();

  for (const connection of activeSse.values()) {
    const ageMs = now - connection.startedAt;
    oldestConnectionAgeMs = Math.max(oldestConnectionAgeMs, ageMs);
    if (now - connection.lastWriteAt > STALLED_WRITE_MS) stalledConnections += 1;
    ageBuckets = bucketAge(ageBuckets, ageMs);
    if (connection.colo) colos.add(connection.colo);
    if (connection.scriptVersion) scriptVersions.add(connection.scriptVersion);
  }
  const sortedColos = Array.from(colos).sort();
  const sortedScriptVersions = Array.from(scriptVersions).sort();

  return {
    activeSseConnections: activeSse.size,
    ageBuckets,
    oldestConnectionAgeMs,
    totalBytesForwarded,
    stalledConnections,
    stalledWriteThresholdMs: STALLED_WRITE_MS,
    colo: sortedColos[0] ?? "",
    colos: sortedColos,
    scriptVersion: sortedScriptVersions[0] ?? "",
    scriptVersions: sortedScriptVersions,
    otel: otelSnapshot(maxQueueSize),
  };
};

const emitSnapshot = (event: string, now: number, maxQueueSize: number): void => {
  lastSnapshotEmittedAt = now;