Struct JobManager 

pub struct JobManager { /* private fields */ }

Manager for background jobs.

Implementations

impl JobManager

pub fn new() -> Self

Create a new job manager.

pub fn spawn<F>(&self, command: String, future: F) -> JobId

where F: Future<Output = ExecResult> + Send + 'static,

Spawn a new background job from a future.

pub async fn register(&self, command: String, rx: Receiver<ExecResult>) -> JobId

Spawn a job that’s already running and communicate via channel.

pub async fn register_with_streams( &self, command: String, rx: Receiver<ExecResult>, stdout: Arc<BoundedStream>, stderr: Arc<BoundedStream>, ) -> JobId

Register a job with attached output streams.

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

pub async fn wait(&self, id: JobId) -> Option<ExecResult>

Wait for a specific job to complete.

pub async fn wait_all(&self) -> Vec<(JobId, ExecResult)>

Wait for all jobs to complete, returning results in completion order.

pub async fn list(&self) -> Vec<JobInfo>

List all jobs with their status.

pub async fn running_count(&self) -> usize

Get the number of running jobs.

pub async fn cleanup(&self)

Remove completed jobs from tracking and clean up their temp files.

pub async fn exists(&self, id: JobId) -> bool

Check if a specific job exists.

pub async fn get(&self, id: JobId) -> Option<JobInfo>

Get info for a specific job.

pub async fn get_command(&self, id: JobId) -> Option<String>

Get the command string for a job.

pub async fn get_status_string(&self, id: JobId) -> Option<String>

Get the status string for a job (for /v/jobs/{id}/status).

pub async fn read_stdout(&self, id: JobId) -> Option<Vec<u8>>

Read stdout stream content for a job.

Returns None if the job doesn’t exist or has no attached stream.

pub async fn read_stderr(&self, id: JobId) -> Option<Vec<u8>>

Read stderr stream content for a job.

Returns None if the job doesn’t exist or has no attached stream.

pub async fn list_ids(&self) -> Vec<JobId>

List all job IDs.

pub async fn register_stopped( &self, command: String, pid: u32, pgid: u32, ) -> JobId

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

pub async fn stop_job(&self, id: JobId, pid: u32, pgid: u32)

Mark a job as stopped with its process info.

pub async fn resume_job(&self, id: JobId)

Mark a stopped job as resumed.

pub async fn last_stopped(&self) -> Option<JobId>

Get the most recently stopped job.

pub async fn get_process_info(&self, id: JobId) -> Option<(u32, u32)>

Get process info (pid, pgid) for a job.

pub async fn remove(&self, id: JobId)

Remove a job from tracking.

Trait Implementations

impl Default for JobManager

fn default() -> Self

Returns the “default value” for a type.