Method worker_statuses

components/scheduler/src/vmworkerpool.rs:285–316

(&self)

    }

    pub fn worker_statuses(&self) -> Vec<WorkerStatus> {
        let w = self.inner.lock().unwrap();

        let mut result = Vec::with_capacity(20);
        for pool in w.pools.iter() {
            for worker in pool.iter() {
                result.push(WorkerStatus {
                    worker_id: worker.worker_id,
                    claimed_last: worker.claimed_at,
                    returned_last: worker.returned_at,
                    priority_index: worker.priority_index,
                    claimed_last_by: worker.last_active_guild,
                    currently_claimed_by: None,
                });
            }
        }

        for pool in &w.claimed_workers {
            for claim in pool {
                result.push(WorkerStatus {
                    worker_id: claim.worker_id,
                    claimed_last: claim.claimed_at,
                    returned_last: claim.returned_last,
                    priority_index: claim.priority_index,
                    claimed_last_by: None,
                    currently_claimed_by: Some(claim.guild_id),
                })
            }
        }

        result
    }
}

#[derive(Debug)]