Enum SchedulerMessage 

pub enum SchedulerMessage {
    Add(Box<TaskDescriptor>),
    Cancel(String),
}

Messages sent to the Scheduler over its control channel.

Obtain the sender from Scheduler::new or Scheduler::with_max_tasks and use it to add or cancel tasks while the scheduler loop is running.

Examples

use tokio::sync::watch;
use zeph_scheduler::{JobStore, Scheduler, SchedulerMessage, TaskDescriptor, TaskKind, TaskMode};
use chrono::Utc;

let store = JobStore::open("sqlite:scheduler.db").await?;
let (_shutdown_tx, shutdown_rx) = watch::channel(false);
let (_scheduler, msg_tx) = Scheduler::new(store, shutdown_rx);

// Add a one-shot task that runs immediately.
let desc = TaskDescriptor {
    name: "generate-report".into(),
    mode: TaskMode::OneShot { run_at: Utc::now() },
    kind: TaskKind::Custom("report".into()),
    config: serde_json::json!({"task": "Generate weekly report"}),
};
msg_tx.send(SchedulerMessage::Add(Box::new(desc))).await?;

// Cancel a previously registered task.
msg_tx.send(SchedulerMessage::Cancel("generate-report".into())).await?;

Variants

Add(Box<TaskDescriptor>)

Register a new task (or replace an existing one with the same name).

Cancel(String)

Cancel and delete the task with the given name.