Method getStats

apps/api/src/queues/queue-manager.ts:177–207

* Snapshot of every managed queue's job counts. Drives the admin * `/admin/queues` endpoint. Pure Valkey reads, safe from a request handler.

()

   * `/admin/queues` endpoint. Pure Valkey reads, safe from a request handler.
   */
  async getStats(): Promise<IQueueStats[]> {
    const queues: { name: string; queue: IManagedQueue }[] = [
      {
        name: this.accountMaintenanceQueue.name,
        queue: this.accountMaintenanceQueue,
      },
      { name: this.emailDeliveryQueue.name, queue: this.emailDeliveryQueue },
      {
        name: this.notificationDispatchQueue.name,
        queue: this.notificationDispatchQueue,
      },
      {
        name: this.notificationMaintenanceQueue.name,
        queue: this.notificationMaintenanceQueue,
      },
    ];

    if (this.webPushDeliveryQueue !== null) {
      queues.push({
        name: this.webPushDeliveryQueue.name,
        queue: this.webPushDeliveryQueue,
      });
    }

    return Promise.all(
      queues.map(async ({ name, queue }) => ({
        name,
        counts: await fetchQueueCounts(queue),
      }))
    );
  }

  async close(): Promise<void> {
    logger.info("Closing queues + workers", {