Interface Scheduler

Scheduler interface for managing job schedules and execution.

interface Scheduler {
    getFailedRegistrations(): string[];
    getRunningJobs(): string[];
    reconcileNow(): void;
    start(): void;
    stop(): Promise<void>;
    triggerJob(jobId: string): Promise<ExecutionResult>;
}

Index

Methods

getFailedRegistrations getRunningJobs reconcileNow start stop triggerJob

Methods

getFailedRegistrations

getFailedRegistrations(): string[]
Get list of job IDs that failed to register cron schedules.

Returns string[]
- Defined in packages/service/src/scheduler/scheduler.ts:50

getRunningJobs

getRunningJobs(): string[]
Get list of currently running job IDs.

Returns string[]
- Defined in packages/service/src/scheduler/scheduler.ts:48

reconcileNow

reconcileNow(): void
Force an immediate reconciliation of job schedules with the database.

Returns void
- Defined in packages/service/src/scheduler/scheduler.ts:46

start

start(): void
Initialize and start the scheduler, loading all enabled jobs.

Returns void
- Defined in packages/service/src/scheduler/scheduler.ts:40

stop

stop(): Promise<void>
Stop the scheduler and gracefully wait for running jobs to complete.

Returns Promise<void>
- Defined in packages/service/src/scheduler/scheduler.ts:42

triggerJob

triggerJob(jobId: string): Promise<ExecutionResult>
Manually trigger a job by ID, bypassing the schedule.
Parameters
- jobId: string
Returns Promise<ExecutionResult>
- Defined in packages/service/src/scheduler/scheduler.ts:44