Struct CronService 

pub struct CronService { /* private fields */ }

Cron scheduling service.

Maintains a registry of interval-based jobs. The daemon calls tick() periodically (e.g., every second) and the service fires any overdue jobs by sending messages through the A2ARouter.

Implementations

impl CronService

pub fn new() -> CronService

pub fn add_job( &self, name: String, interval_secs: u64, command: String, target_pid: Option<u64>, ) -> CronJob

Add a new cron job. Returns the created job.

pub fn remove_job(&self, id: &str) -> Option<CronJob>

Remove a job by ID. Returns the removed job if it existed.

pub fn list_jobs(&self) -> Vec<CronJob>

List all registered jobs.

pub fn get_job(&self, id: &str) -> Option<CronJob>

Look up a single job by ID.

pub fn tick(&self) -> TickResult

Tick the scheduler — check all jobs and collect those that are overdue.

Returns the list of job IDs that should fire. The caller is responsible for actually dispatching the messages (to keep CronService decoupled from async A2ARouter).

pub fn job_snapshot(&self, id: &str) -> Option<CronJob>

Get a snapshot of a job’s current state (for dispatching after tick).

pub fn job_count(&self) -> usize

Number of registered jobs.

Trait Implementations

impl Default for CronService

fn default() -> CronService

Returns the “default value” for a type.

impl SystemService for CronService

fn name(&self) -> &str

Human-readable service name.

fn service_type(&self) -> ServiceType

Service type category.

fn start<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

where 'life0: 'async_trait, CronService: 'async_trait,

Start the service.

fn stop<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send + 'async_trait>>

where 'life0: 'async_trait, CronService: 'async_trait,

Stop the service.

fn health_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = HealthStatus> + Send + 'async_trait>>

where 'life0: 'async_trait, CronService: 'async_trait,

Perform a health check.

fn liveness_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ProbeResult> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Liveness probe (K2b-G2, os-patterns).

fn readiness_check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ProbeResult> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Readiness probe (K2b-G2, os-patterns).