Struct WorkerInfo 

pub struct WorkerInfo {
    pub id: String,
    pub name: String,
    pub tags: Vec<String>,
    pub gpu: bool,
    pub cpu_cores: usize,
    pub active_jobs: usize,
    pub max_concurrent: usize,
}

A worker’s capabilities and current load.

Fields

id: String

Stable identifier assignments and transfers refer to.

name: String

Human-readable name, carried into Assignment::worker_name so a distribution plan reads without a worker lookup.

tags: Vec<String>

Capability tags (e.g. "gpu") matched against a plan’s RemoteTarget::Tag requirements.

gpu: bool

Whether the worker has a GPU.

cpu_cores: usize

CPU cores available on the worker.

active_jobs: usize

Jobs currently running; the load side of available_slots.

max_concurrent: usize

Upper bound on concurrent jobs; the capacity side of available_slots.

Implementations

impl WorkerInfo

pub fn available_slots(&self) -> usize

How many more jobs this worker can take right now. Saturates at zero: a worker reporting more active jobs than its limit is full, not underflowed.

pub fn has_capacity(&self) -> bool

Whether the worker can take at least one more job. schedule filters on this before any placement is attempted.

pub fn matches_tag(&self, tag: &str) -> bool

Whether the worker advertises tag among its capability tags.

Trait Implementations

impl Clone for WorkerInfo

fn clone(&self) -> WorkerInfo

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for WorkerInfo

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for WorkerInfo

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for WorkerInfo

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.