Struct JobController 

pub struct JobController {
    pub abort_tx: Sender<()>,
    pub stop_tx: Sender<()>,
    pub resume_tx: Sender<()>,
}

Control-plane senders for a running job, kept by actor_system_loop and looked up by job_id when the user calls abort_job / stop_job / resume_job. Each channel carries () signals only; the job loop awakens via tokio::select! and decides what to do.

Users don’t construct or inspect this directly — it lives behind the abort_job / stop_job / resume_job methods on ActorSystem.

Fields

abort_tx: Sender<()>

Signal the job loop to exit immediately. Honored at every wait point (start_at, pause-for-resume, inter-iteration sleep).

stop_tx: Sender<()>

Signal the job loop to pause after the current iteration. The loop then waits on resume_tx (or abort_tx) before continuing.

resume_tx: Sender<()>

Signal a stopped job to continue iterating.

Trait Implementations

impl Clone for JobController

fn clone(&self) -> JobController

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.