schedule

Documentation

Index

• Variables
• func CreateSchedule(jobname, schedule string, cmd func()) error
• type CronZaplog
  • func (c *CronZaplog) Error(err error, msg string, keysAndValues ...interface{})
  • func (c *CronZaplog) Info(msg string, keysAndValues ...interface{})
• type JobParams
• type JobSchedule
• type ScheduleLoker
  • func (sl *ScheduleLoker) Create(name, schedule string) error
  • func (sl *ScheduleLoker) Wrapper() cron.JobWrapper

Variables

var ScheduleLockerEnabled = true

Functions

func CreateSchedule

func CreateSchedule(jobname, schedule string, cmd func()) error

Types

type CronZaplog

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

func (*CronZaplog) Error

func (c *CronZaplog) Error(err error, msg string, keysAndValues ...interface{})

func (*CronZaplog) Info

func (c *CronZaplog) Info(msg string, keysAndValues ...interface{})

type JobParams

type JobParams struct {
	dig.In
	DB     *gorm.DB `optional:"true"`
	Logger *zap.Logger
	Bus    EventBus.Bus `optional:"true"`
}

type JobSchedule

type JobSchedule struct {
	Name         string `gorm:"size:64;primarykey"`
	CreatedAt    time.Time
	UpdatedAt    time.Time
	Schedule     string `gorm:"size:32"`
	LastRuntime  *time.Time
	LastDuration time.Duration
}

It's for job locker

type ScheduleLoker

type ScheduleLoker struct {
	Logger  *zap.Logger
	DB      *gorm.DB
	Bus     EventBus.Bus
	Jobname string
}

func (*ScheduleLoker) Create

func (sl *ScheduleLoker) Create(name, schedule string) error

func (*ScheduleLoker) Wrapper

func (sl *ScheduleLoker) Wrapper() cron.JobWrapper