README

Nest Schedule

Name: nest-schedule
Rating: 14 (1 reviews)

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');
  }
}

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

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

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

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

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

nest-schedule

README

Nest Schedule

Description

Installation

Usage

Dynamic Schedule Job

Distributed Support

1. Extend NestDistributedSchedule class

GitHub Stats

Security

Downloads

Used By

2. Use UseLocker decorator

API

class ScheduleModule

static register(config: IGlobalConfig): DynamicModule

class Schedule

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

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

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

cancelJob(key: string)

Decorators

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

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

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

InjectSchedule(): PropertyDecorator

UseLocker(locker: ILocker | Function): MethodDecorator

Stay in touch

License

Details

Health Status