Struct JobExecutor 

pub struct JobExecutor { /* private fields */ }

Job executor handles run-to-completion workloads

Implementations

impl JobExecutor

pub fn new(runtime: Arc<dyn Runtime + Send + Sync>) -> Self

Create a new job executor with default configuration

pub fn with_config( runtime: Arc<dyn Runtime + Send + Sync>, config: JobExecutorConfig, ) -> Self

Create a new job executor with custom configuration

pub async fn register_job(&self, name: &str, spec: ServiceSpec)

Register a job spec (for later triggering)

pub async fn unregister_job(&self, name: &str)

Unregister a job spec

pub async fn get_job_spec(&self, name: &str) -> Option<ServiceSpec>

Get a registered job spec

pub async fn trigger( &self, job_name: &str, spec: &ServiceSpec, trigger: JobTrigger, ) -> Result<JobExecutionId>

Trigger a job execution

Errors

Returns an error if the job container cannot be created or started.

pub async fn get_execution( &self, exec_id: &JobExecutionId, ) -> Option<JobExecution>

Get the status of a job execution

pub async fn list_executions(&self, job_name: &str) -> Vec<JobExecution>

List all executions for a job

pub async fn list_all_executions(&self) -> Vec<JobExecution>

List all executions (across all jobs)

pub async fn cancel(&self, exec_id: &JobExecutionId) -> Result<()>

Cancel a running job execution

Errors

Returns an error if the execution is not found or not in a cancellable state.

pub async fn cleanup_old_executions(&self)

Clean up old execution records

pub fn shutdown(&self)

Signal shutdown

pub fn is_shutting_down(&self) -> bool

Check if executor is shutting down

pub async fn active_execution_count(&self) -> usize

Get the number of active (non-completed) executions