Struct MegatronQueue 

pub struct MegatronQueue { /* private fields */ }

A Queue over a fleet mission’s projects. Shells fno megatron next / fno megatron complete; never touches the fleet directory itself.

Implementations

impl MegatronQueue

pub fn new(abi_bin: String, mission_id: String) -> Self

Trait Implementations

impl Queue for MegatronQueue

fn next(&mut self) -> Result<Option<Unit>, LoopError>

Dequeue the next incomplete project of the mission.

fno megatron next <mission> --json contract:

• null -> mission complete -> Ok(None)
• {"pause": {"policy","detail"}} -> Err(LoopError::Pause{policy, detail}) (run_loop maps this to walk_paused + NoProgress)
• unit object -> Some(Unit)

fn close( &mut self, unit: &Unit, evidence: &Evidence, ) -> Result<CloseOutcome, LoopError>

Record the child walk’s outcome against the mission.

NoWork (walk drained) | DonePRGreen | DoneAdvisory -> complete --outcome done -> Closed. Anything else -> complete --outcome failed (the verb pauses the mission) -> Parked; the NEXT next() call returns the pause and run_loop terminates NoProgress.

fn next_step(&mut self) -> Result<NextStep, LoopError>

Richer variant of next() that can signal a walk-level pause. Policy-aware queues override this; simple queues (TargetQueue) can leave the default which panics (they override next() directly instead).