cron_jobs

Documentation

Index

• Variables
• func DailyJobScheduler()
• func InitKafkaConn()
• func JobScheduler(jobs []models.Job)
• func ScheduleDailyJob()
• func ScheduleJobOnServerStart()
• func SendScheduledMail(job models.Job) error
• func SetCronJob(cronSchedulerType CronScheduler, job models.Job, ...)
• type CronScheduler
  • func GetNewCron() CronScheduler

Variables

var KafkaConn *kafka.Conn

Functions

func DailyJobScheduler

func DailyJobScheduler()

Daily job scheduler ...

func InitKafkaConn

func InitKafkaConn()

func JobScheduler

func JobScheduler(jobs []models.Job)

Job scheduler ...

func ScheduleDailyJob

func ScheduleDailyJob()

Schedule the daily active jobs ...

func ScheduleJobOnServerStart

func ScheduleJobOnServerStart()

Server startup job scheduler ...

func SendScheduledMail

func SendScheduledMail(job models.Job) error

Send the scheduled mails ...

func SetCronJob

func SetCronJob(cronSchedulerType CronScheduler, job models.Job, fn func(job2 models.Job) error)

Ass the cron jobs before start ...

Types

type CronScheduler

type CronScheduler struct {
	// contains filtered or unexported fields
}

CronScheduler ...

func GetNewCron

func GetNewCron() CronScheduler

cron constructor ...