Merge pull request #58 from WideChat/run_now_scheduler

[NEW] Run now scheduler

Author: ear-dev

definition/accessors/ISchedulerModify.d.ts

@@ -1,4 +1,4 @@
-import { IOnetimeSchedule, IRecurringSchedule } from '../scheduler';
+import { IOnetimeSchedule, IRecurringSchedule, IRunNow } from '../scheduler';
 /**
  * This accessor provides methods to work with the Job Scheduler
  */
@@ -17,6 +17,13 @@ export interface ISchedulerModify {
      * @returns jobid as string
      */
     scheduleRecurring(job: IRecurringSchedule): Promise<void | string>;
+    /**
+     * Schedules a registered processor to run now
+     *
+     * @param {IRunNow} job
+     * @returns jobid as string
+     */
+    runNow(job: IRunNow): Promise<void | string>;
     /**
      * Cancels a running job given its jobId
      *

definition/accessors/ISchedulerModify.js.map

@@ -0,0 +1,7 @@
+/** Represents a job that runs onow */
+export interface IRunNow {
+    /** The schedule's identifier */
+    id: string;
+    /** An object that can be passed to the processor with custom data */
+    data?: object;
+}

definition/scheduler/IRunNow.d.ts

@@ -1,3 +1,4 @@
 export { IOnetimeSchedule } from './IOnetimeSchedule';
 export { IProcessor, IJobContext, IOnetimeStartup, IRecurringStartup, StartupType } from './IProcessor';
 export { IRecurringSchedule } from './IRecurringSchedule';
+export { IRunNow } from './IRunNow';

definition/scheduler/IRunNow.js

@@ -7,6 +7,7 @@ export declare class SchedulerModify implements ISchedulerModify {
     constructor(bridge: SchedulerBridge, appId: string);
     scheduleOnce(job: IOnetimeSchedule): Promise<void | string>;
     scheduleRecurring(job: IRecurringSchedule): Promise<void | string>;
+    runNow(job: IRecurringSchedule): Promise<void | string>;
     cancelJob(jobId: string): Promise<void>;
     cancelAllJobs(): Promise<void>;
     cancelJobByDataQuery(data: object): Promise<void>;