Skip to content
A cron-like and not-cron-like job distributed scheduler for Nest.js by decorators.
TypeScript JavaScript
Branch: master
Clone or download
Latest commit 593d884 Jul 18, 2019
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
lib fixes #31, assert job not exist when schedule job Jul 19, 2019
samples Bump lodash from 4.17.11 to 4.17.14 in /samples Jul 13, 2019
.eslintrc.js initial commit Jun 22, 2018
.gitignore support dynamic schedule a job & add UseLocker decorator Apr 23, 2019
.npmignore support dynamic schedule a job & add UseLocker decorator Apr 23, 2019
.prettierrc initial commit Jun 22, 2018
LICENSE add license Apr 2, 2019
README.md update doc Jun 28, 2019
index.d.ts initial commit Jun 22, 2018
index.js initial commit Jun 22, 2018
index.ts.js initial commit Jun 22, 2018
package.json 0.6.3 Jul 19, 2019
tsconfig.json
tslint.json initial commit Jun 22, 2018
yarn.lock Bump lodash from 4.17.11 to 4.17.14 Jul 12, 2019

README.md

Nest Logo

Nest Schedule

NPM Version Package License NPM Downloads

Description

This is a Nest module for using decorator schedule jobs.

Installation

$ npm i --save nest-schedule

Usage

import { Module } from '@nestjs/common';
import { ScheduleModule } from 'nest-schedule';

@Module({
  imports: [
    ScheduleModule.register(),
  ]
})
export class AppModule {
}
import { Injectable } from '@nestjs/common';
import { Cron, Interval, Timeout, NestSchedule } from 'nest-schedule';

@Injectable() // Only support SINGLETON scope
export class ScheduleService extends NestSchedule {    
  @Cron('0 0 2 * *', {
    startTime: new Date(), 
    endTime: new Date(new Date().getTime() + 24 * 60 * 60 * 1000),
  })
  async cronJob() {
    console.log('executing cron job');
  }
  
  @Timeout(5000)
  onceJob() {
    console.log('executing once job');
  }
  
  @Interval(2000)
  intervalJob() {
    console.log('executing interval job');
    
    // if you want to cancel the job, you should return true;
    return true;
  }
}

Dynamic Schedule Job

import { Injectable } from '@nestjs/common';
import { InjectSchedule, Schedule } from 'nest-schedule';

@Injectable()
export class ScheduleService {    
  constructor(
    @InjectSchedule() private readonly schedule: Schedule,
  ) {
  }
  
  createJob() {
    // schedule a 2s interval job
    this.schedule.scheduleIntervalJob('my-job', 2000, () => {
      console.log('executing interval job');
    });
  }
  
  cancelJob() {
    this.schedule.cancelJob('my-job');
  }
}

Distributed Support

1. Extend NestDistributedSchedule class

import { Injectable } from '@nestjs/common';
import { Cron, NestDistributedSchedule } from 'nest-schedule';

@Injectable()
export class ScheduleService extends NestDistributedSchedule {  
  constructor() {
    super();
  }
  
  async tryLock(method: string) {
    if (lockFail) {
      return false;
    }
    
    return () => {
      // Release here.
    }
  }
  
  @Cron('0 0 4 * *')
  async cronJob() {
    console.log('executing cron job');
  }
}

2. Use UseLocker decorator

import { ILocker, IScheduleConfig, InjectSchedule, Schedule } from 'nest-schedule';
import { Injectable } from '@nestjs/common';

// If use NestCloud, it supports dependency injection.
@Injectable()
export class MyLocker implements ILocker {
  private key: string;
  private config: IScheduleConfig;

  constructor(
    @InjectSchedule() private readonly schedule: Schedule,
  ) {
  }

  init(key: string, config: IScheduleConfig): void {
    this.key = key;
    this.config = config;
    console.log('init my locker: ', key, config);
  }

  release(): any {
    console.log('release my locker');
  }

  tryLock(): Promise<boolean> | boolean {
    console.log('apply my locker');
    return true;
  }
}
import { Injectable } from '@nestjs/common';
import { Cron, NestSchedule, UseLocker } from 'nest-schedule';
import { MyLocker } from './my.locker';

@Injectable()
export class ScheduleService extends NestSchedule {  
  @Cron('0 0 4 * *')
  @UseLocker(MyLocker)
  async cronJob() {
    console.log('executing cron job');
  }
}

API

class ScheduleModule

static register(config: IGlobalConfig): DynamicModule

Register schedule module.

field type required description
config.enable boolean false default is true, when false, the job will not execute
config.maxRetry number false the max retry count, default is -1 not retry
config.retryInterval number false the retry interval, default is 5000
config.waiting boolean false the scheduler will not schedule job when this job is running, if waiting is true

class Schedule

scheduleCronJob(key: string, cron: string, callback: JobCallback, config?: ICronJobConfig)

Schedule a cron job.

field type required description
key string true The unique job key
cron string true The cron expression
callback () => Promise<boolean> boolean If return true in callback function, the schedule will cancel this job immediately
config.startTime Date false The start time of this job
config.endTime Date false The end time of this job
config.enable boolean false default is true, when false, the job will not execute
config.maxRetry number false the max retry count, default is -1 not retry
config.retryInterval number false the retry interval, default is 5000
config.waiting boolean false the scheduler will not schedule job when this job is running, if waiting is true
config.immediate boolean false running job immediately

scheduleIntervalJob(key: string, interval: number, callback: JobCallback, config?: IJobConfig)

Schedule a interval job.

field type required description
key string true The unique job key
interval number true milliseconds
callback () => Promise<boolean> boolean If return true in callback function, the schedule will cancel this job immediately
config.enable boolean false default is true, when false, the job will not execute
config.maxRetry number false the max retry count, default is -1 not retry
config.retryInterval number false the retry interval, default is 5000
config.waiting boolean false the scheduler will not schedule job when this job is running, if waiting is true
config.immediate boolean false running job immediately

scheduleTimeoutJob(key: string, timeout: number, callback: JobCallback, config?: IJobConfig)

Schedule a timeout job.

field type required description
key string true The unique job key
timeout number true milliseconds
callback () => Promise<boolean> boolean If return true in callback function, the schedule will cancel this job immediately
config.enable boolean false default is true, when false, the job will not execute
config.maxRetry number false the max retry count, default is -1 not retry
config.retryInterval number false the retry interval, default is 5000
config.immediate boolean false running job immediately

cancelJob(key: string)

Cancel job.

Decorators

Cron(expression: string, config?: ICronJobConfig): MethodDecorator

Schedule a cron job.

field type required description
expression string true the cron expression
config.key string false The unique job key
config.startTime Date false the job's start time
config.endTime Date false the job's end time
config.enable boolean false default is true, when false, the job will not execute
config.maxRetry number false the max retry count, default is -1 not retry
config.retryInterval number false the retry interval, default is 5000
config.waiting boolean false the scheduler will not schedule job when this job is running, if waiting is true
config.immediate boolean false running job immediately

Interval(milliseconds: number, config?: IJobConfig): MethodDecorator

Schedule a interval job.

field type required description
milliseconds number true milliseconds
config.key string false The unique job key
config.enable boolean false default is true, when false, the job will not execute
config.maxRetry number false the max retry count, default is -1 not retry
config.retryInterval number false the retry interval, default is 5000
config.waiting boolean false the scheduler will not schedule job when this job is running, if waiting is true
config.immediate boolean false running job immediately

Timeout(milliseconds: number, config?: IJobConfig): MethodDecorator

Schedule a timeout job.

field type required description
milliseconds number true milliseconds
config.key string false The unique job key
config.enable boolean false default is true, when false, the job will not execute
config.maxRetry number false the max retry count, default is -1 not retry
config.retryInterval number false the retry interval, default is 5000
config.immediate boolean false running job immediately

InjectSchedule(): PropertyDecorator

Inject Schedule instance

UseLocker(locker: ILocker | Function): MethodDecorator

Make your job support distribution.

If you use NestCloud, the Locker will support dependency injection, or not use injection please.

Stay in touch

License

You can’t perform that action at this time.