Method getHeartbeatMeta

src/proxy/task/monitor.js:116–128

()

  }

  getHeartbeatMeta() {
    const pendingTasks = this.store.countPending({ direction: 'inbound' });
    return {
      task_subscription: this.subscribed,
      task_metrics: {
        pending: pendingTasks,
        claimed: this._stats.tasks_claimed,
        completed: this._stats.tasks_completed,
        failed: this._stats.tasks_failed,
        avg_completion_ms: this._stats.avg_completion_ms,
      },
    };
  }
}

module.exports = { TaskMonitor };