Struct BackgroundProcessManager 

pub struct BackgroundProcessManager { /* private fields */ }

Manages background processes like port-forwards.

Thread-safe and designed to be shared across the agent session.

Implementations

impl BackgroundProcessManager

pub fn new() -> Self

Create a new background process manager.

pub async fn start_port_forward( &self, id: &str, resource: &str, namespace: &str, target_port: u16, ) -> Result<u16, BackgroundProcessError>

Start a kubectl port-forward in the background.

Returns the local port that was allocated.

Arguments

• id - Unique identifier for this port-forward
• resource - Kubernetes resource (e.g., “svc/prometheus-server” or “pod/prometheus-0”)
• namespace - Kubernetes namespace
• target_port - The port on the remote resource

Example

let port = manager.start_port_forward(
    "prometheus",
    "svc/prometheus-server",
    "monitoring",
    9090
).await?;

pub async fn start( &self, id: &str, command: &str, working_dir: &Path, ) -> Result<(), BackgroundProcessError>

Start a generic background command.

Arguments

• id - Unique identifier for this process
• command - The command to execute
• working_dir - Working directory for the command

pub async fn stop(&self, id: &str) -> Result<(), BackgroundProcessError>

Stop a background process by ID.

pub async fn is_running(&self, id: &str) -> bool

Check if a process is running.

pub async fn get(&self, id: &str) -> Option<ProcessInfo>

Get information about a specific process.

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

List all background processes.

pub async fn stop_all(&self)

Stop all background processes.

Trait Implementations

impl Default for BackgroundProcessManager

fn default() -> Self

Returns the “default value” for a type.

impl Drop for BackgroundProcessManager

fn drop(&mut self)

Executes the destructor for this type.