scheduler

Documentation

Index

• func Bootstrap(k *dislet.Kernel)
• func Consumption(lineId uint) error
• func SchedulerJob(jobId string) *tasks.Signature
• type Job
• type MysqlJob

Functions

func Bootstrap

func Bootstrap(k *dislet.Kernel)

func Consumption

func Consumption(lineId uint) error

func SchedulerJob

func SchedulerJob(jobId string) *tasks.Signature

Types

type Job

type Job struct {
	LineId          uint
	LastResult      string
	Period          time.Duration
	LastRun         time.Time
	NextRun         time.Time
	ContinueRunning bool
	MaxPeriod       time.Duration
	MinPeriod       time.Duration
	IncrementRatio  float32
	DecrementRatio  float32
}

type MysqlJob

type MysqlJob struct {
	gorm.Model
	LastResult      string
	Period          uint
	LastRun         time.Time
	NextRun         time.Time
	ContinueRunning bool
	MaxPeriod       uint
	MinPeriod       uint
	IncrementRatio  float32 `sql:"type:decimal(4,2);"`
	DecrementRatio  float32 `sql:"type:decimal(4,2);"`
}