Function inspectBuffers

packages/db/scripts/check-sessions.ts:127–147

()

}

async function inspectBuffers() {
  const redis = getRedisCache();
  const [eventCounter, sessionCounter, eventListLen, sessionListLen] =
    await Promise.all([
      redis.get('buffer-counter:event'),
      redis.get('buffer-counter:session'),
      redis.llen('event-buffer'),
      redis.llen('session-buffer'),
    ]);

  return {
    event: {
      counter: Number(eventCounter ?? 0),
      listLen: Number(eventListLen ?? 0),
    },
    session: {
      counter: Number(sessionCounter ?? 0),
      listLen: Number(sessionListLen ?? 0),
    },
  };
}

async function inspectClickhouse(
  projects: string[] | null,