scheduler

Documentation

Overview

Package scheduler provides ability to create scheduled job

Index

• func CreateScheduler(log log.T, task func(), frequencyInMinutes int) (job *scheduler.Job, err error)
• func ScheduleNextRun(j *scheduler.Job)
• func Stop(job *scheduler.Job)

Functions

func CreateScheduler

func CreateScheduler(log log.T, task func(), frequencyInMinutes int) (job *scheduler.Job, err error)

CreateScheduler runs a given poll job every pollFrequencyMinutes

func ScheduleNextRun

func ScheduleNextRun(j *scheduler.Job)

ScheduleNextRun skips waiting and schedule next run immediately

func Stop

func Stop(job *scheduler.Job)

Stop stops the scheduler.