Method getMetrics

src/proxy/task/monitor.js:101–114

()

  }

  getMetrics() {
    const pendingTasks = this.store.countPending({ direction: 'inbound' });
    return {
      subscribed: this.subscribed,
      tasks_received: this._stats.tasks_received,
      tasks_claimed: this._stats.tasks_claimed,
      tasks_completed: this._stats.tasks_completed,
      tasks_failed: this._stats.tasks_failed,
      tasks_pending: pendingTasks,
      last_claim_at: this._stats.last_claim_at,
      last_complete_at: this._stats.last_complete_at,
      avg_completion_ms: this._stats.avg_completion_ms,
    };
  }

  getHeartbeatMeta() {
    const pendingTasks = this.store.countPending({ direction: 'inbound' });