Struct Job 

pub struct Job {
    pub id: JobId,
    pub command: String,
    /* private fields */
}

A background job.

Fields

id: JobId

Job ID.

command: String

Command description.

Implementations

impl Job

pub fn new(id: JobId, command: String, handle: JoinHandle<ExecResult>) -> Self

Create a new job from a task handle.

pub fn from_channel( id: JobId, command: String, rx: Receiver<ExecResult>, ) -> Self

Create a new job from a result channel.

pub fn with_streams( id: JobId, command: String, rx: Receiver<ExecResult>, stdout: Arc<BoundedStream>, stderr: Arc<BoundedStream>, ) -> Self

Create a new job with attached output streams.

The streams provide live access to job output via /v/jobs/{id}/stdout and /stderr.

pub fn stopped(id: JobId, command: String, pid: u32, pgid: u32) -> Self

Create a stopped job (from Ctrl-Z on a foreground process).

pub fn output_file(&self) -> Option<&PathBuf>

Get the output file path (if available).

pub fn is_done(&mut self) -> bool

Check if the job has completed.

Stopped jobs are not considered done.

pub fn status(&mut self) -> JobStatus

Get the job’s status.

pub fn status_string(&mut self) -> String

Get the job’s status as a string suitable for /v/jobs/{id}/status.

Returns:

• "running" if the job is still running
• "done:0" if the job completed successfully
• "failed:{code}" if the job failed with an exit code

pub fn stdout_stream(&self) -> Option<&Arc<BoundedStream>>

Get the stdout stream (if attached).

pub fn stderr_stream(&self) -> Option<&Arc<BoundedStream>>

Get the stderr stream (if attached).

pub async fn wait(&mut self) -> ExecResult

Wait for the job to complete and return its result.

On completion, the job’s output is written to a temp file for later retrieval.

pub fn cleanup_files(&mut self)

Remove any temp files associated with this job.

pub fn try_result(&self) -> Option<&ExecResult>

Get the result if completed, without waiting.

pub fn try_poll(&mut self) -> bool

Try to poll the result channel and update status.

This is a non-blocking check that updates self.result if the job has completed. Returns true if the job is now done.