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 fn set_overlay_manager( &mut self, overlay_manager: Arc<RwLock<OverlayManager>>, )

Attach an overlay manager so job (and cron) containers join the overlay network and can reach the daemon API / peer services. Without this, a job container comes up with only a loopback netns and any call to the daemon node IP fails with ENETUNREACH.

pub fn set_token_sink(&mut self, sink: Arc<dyn ContainerTokenSink>)

Set the sink used to persist/revoke per-container scoped tokens.

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 registered_job_names(&self) -> Vec<String>

Names of all registered jobs, sorted.

pub async fn latest_execution(&self, job_name: &str) -> Option<JobExecution>

The most recent execution for a job name, if any (the one that started last; a not-yet-started execution sorts before any started one).

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