jobscheduler

Documentation

Index

• Variables
• func ActionLoop(qs *gorm.DB, doOneModel DoOneModel)
• func Loop()
• func NotifyJob(ret *gorm.DB, j model.Job, status model.JobStatus)
• func RunningJobs()
• type DoOneModel

Variables

var Limit int = 5000

var Wait *sync.WaitGroup

Functions

func ActionLoop

func ActionLoop(qs *gorm.DB, doOneModel DoOneModel)

func Loop

func Loop()

func NotifyJob

func NotifyJob(ret *gorm.DB, j model.Job, status model.JobStatus)

func RunningJobs

func RunningJobs()

Types

type DoOneModel

type DoOneModel func(j model.Job)