Struct FleetWorkerConfig 

pub struct FleetWorkerConfig {
    pub accepts_work: bool,
    pub repos: Vec<PathBuf>,
    pub max_parallel: u32,
    pub local_parallel: u32,
    pub dispatches_per_hour: u32,
    pub max_subtask_secs: u64,
    pub fetch_missing_base: bool,
    pub fetch_remote: String,
    pub allowed_tools: Option<Vec<String>>,
}

Whether this instance takes farmed-out coding work, and under what limits.

Persisted at ~/.car/fleet-worker.json (under CAR_HOME when set) rather than read from the environment, because it is an operator decision that must survive a restart and be inspectable — an env var would make “does this machine run my peers’ prompts?” depend on how the daemon happened to be launched.

Fields

accepts_work: bool

Off by default. Turning it on lets a trusted peer run a coding CLI against the checkouts named in repos.

repos: Vec<PathBuf>

Repository checkouts this host will serve. A dispatch is matched to one of these by root commit; anything else is declined.

max_parallel: u32

Peers’ subtasks run here at once.

local_parallel: u32

This host’s own share when it orchestrates a distributed run. Separate from max_parallel, which bounds what peers may spend here.

dispatches_per_hour: u32

Dispatches ONE peer may start here per hour.

max_parallel bounds concurrency, which is not a bound on spend: a peer that dispatches one subtask, waits, and dispatches the next never exceeds it and can still drain this machine’s coding-CLI quota. This is the budget. 0 accepts nothing while keeping the rest of the config.

max_subtask_secs: u64

Hard ceiling on a peer-supplied timeout_secs.

The dispatch carries a timeout the sender chose. A machine agreeing to take work is not agreeing to be occupied for as long as the caller likes, so the sender’s value is clamped to this and an omitted one defaults to it.

fetch_missing_base: bool

Fetch a missing base commit from this checkout’s own remote instead of declining — the posture that makes a machine a runner rather than a person’s laptop.

Off by default, because on a laptop it means a peer’s dispatch can cause a network fetch in a repository the operator is working in. On a runner it is the whole point: a machine that continuously tracks origin always has the base commit, which is what turns an idle pool into a working one. Adds no trust — the fetch targets the remote this checkout is already configured with, never anything the dispatch supplied.

fetch_remote: String

Remote a runner fetches from. origin unless an operator says otherwise.

allowed_tools: Option<Vec<String>>

Tools a peer’s coding CLI may use here, intersected with whatever the dispatch asks for.

None (the default) adds no restriction beyond the CLI’s own, which is the honest default: a coding subtask needs to read, edit, and usually build, so a narrow allowlist mostly turns into every dispatch failing for reasons the sender cannot see. Set it when this machine should be stricter than the work requires.

Implementations

impl FleetWorkerConfig

pub fn load() -> Self

Read the config, falling back to the declining default.

A malformed file reads as the default rather than as an error: the failure mode of “unparseable config” must be declining work, never accepting it under a half-read set of limits.

pub fn save(&self) -> Result<(), String>

Trait Implementations

impl Clone for FleetWorkerConfig

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FleetWorkerConfig

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

Formats the value using the given formatter.

impl Default for FleetWorkerConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for FleetWorkerConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for FleetWorkerConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.