schedule

Documentation

Index

• Constants
• Variables
• func CheckIfEnabled() cron.JobWrapper
• func CreateSchedule(jobname, schedule string, cmd func()) error
• func DoCleanup(settingkey string, tables []string, col string, duration string) interface{}
• func InitDBCronJob(logger *zap.Logger, db *gorm.DB) (core.Startup, error)
• func InitScheduleCleanupJob(settingkey string) interface{}
• func Withhistory(bus EventBus.Bus, jobname string) cron.JobWrapper
• type CleanupService
  • func (cs *CleanupService) Cleanup(req *DBCleanupReq) error
  • func (cs *CleanupService) GetDefaultRequest() *DBCleanupReq
  • func (cs *CleanupService) RegConnection(name string, db *gorm.DB)
• type CronZaplog
  • func (c *CronZaplog) Error(err error, msg string, keysAndValues ...interface{})
  • func (c *CronZaplog) Info(msg string, keysAndValues ...interface{})
• type DBCleanupReq
• type DBCronJob
  • func (job *DBCronJob) FireJob()
• type JobHistory
• type JobParams
• type ScheduleLoker
  • func (sl *ScheduleLoker) Wrapper() cron.JobWrapper

Constants

const (
	// EventJobStarted  = "event.job.started"
	// EventJobDone     = "event.job.done"
	// EventJobFailed   = "event.job.failed"
	EventJobFinished = "event.job.finished"
	EventJobFailed   = "event.job.failed"
)

Variables

var JobHistoryEnabled = true

var LockerTimeout = 50 * time.Millisecond

var ScheduleDisabled = false

var ScheduleLockerEnabled = true

Functions

func CheckIfEnabled

func CheckIfEnabled() cron.JobWrapper

func CreateSchedule

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

func DoCleanup

func DoCleanup(settingkey string, tables []string, col string, duration string) interface{}

func InitDBCronJob

func InitDBCronJob(logger *zap.Logger, db *gorm.DB) (core.Startup, error)

func InitScheduleCleanupJob

func InitScheduleCleanupJob(settingkey string) interface{}

func Withhistory

func Withhistory(bus EventBus.Bus, jobname string) cron.JobWrapper

Types

type CleanupService

type CleanupService struct {
	DBMap map[string]*gorm.DB
	// contains filtered or unexported fields
}

func (*CleanupService) Cleanup

func (cs *CleanupService) Cleanup(req *DBCleanupReq) error

func (*CleanupService) GetDefaultRequest

func (cs *CleanupService) GetDefaultRequest() *DBCleanupReq

func (*CleanupService) RegConnection

func (cs *CleanupService) RegConnection(name string, db *gorm.DB)

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 DBCleanupReq

type DBCleanupReq struct {
	Cnn          string   //connection name
	Tables       []string //tables to be clean
	DeletedField string   //field name, default is deletedAt
	Duration     string   // only delete DeletedAt <  now - duration
	Batch        int      // batch per deleted
}

type DBCronJob

type DBCronJob struct {
	Name     string
	Schedule string
	Sql      []string
	// contains filtered or unexported fields
}

func (*DBCronJob) FireJob

func (job *DBCronJob) FireJob()

type JobHistory

type JobHistory struct {
	Job      string
	Start    time.Time
	Finished time.Time
	Duration time.Duration
	Succeed  bool
	Message  string
}

type JobParams

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

type ScheduleLoker

type ScheduleLoker struct {
	Locker  locker.Locker
	Bus     EventBus.Bus
	Jobname string
}

func (*ScheduleLoker) Wrapper

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