jtask

Documentation

Index

• func Now() time.Time
• type CronDataTaskJob
  • func NewDataJob(time string, workFun func(s string, data interface{}), data interface{}) *CronDataTaskJob
  • func (ct *CronDataTaskJob) Run()
• type CronTask
  • func New(seconds bool) *CronTask
  • func (cm *CronTask) AddTask(t *CronTaskJob) error
  • func (cm *CronTask) AddTaskWithData(t *CronDataTaskJob) error
  • func (cm *CronTask) DelTask(id int) error
  • func (cm *CronTask) StartTask() error
  • func (cm *CronTask) StopTask() error
• type CronTaskJob
  • func NewJob(time string, fun func(s string), data interface{}) *CronTaskJob
  • func (ct *CronTaskJob) Run()
• type CronTimeTaskJob
  • func NewTimeJob(time time.Time, workFun func(s string, data interface{}), data interface{}) *CronTimeTaskJob
  • func (ct *CronTimeTaskJob) Run()

Functions

func Now

func Now() time.Time

Types

type CronDataTaskJob

type CronDataTaskJob struct {
	Time    string
	TaskId  string
	WorkFun func(s string, data interface{})
	RunId   int
	Data    interface{}
}

/define data job

func NewDataJob

func NewDataJob(time string, workFun func(s string, data interface{}), data interface{}) *CronDataTaskJob

func (*CronDataTaskJob) Run

func (ct *CronDataTaskJob) Run()

/define the task

type CronTask

type CronTask struct {
	CronInstance *cron.Cron
	WithSeconds  bool
	// contains filtered or unexported fields
}

/define the cron wrapper

func New

func New(seconds bool) *CronTask

/cron manager builder

func (*CronTask) AddTask

func (cm *CronTask) AddTask(t *CronTaskJob) error

/add a task

func (*CronTask) AddTaskWithData

func (cm *CronTask) AddTaskWithData(t *CronDataTaskJob) error

/add a task

func (*CronTask) DelTask

func (cm *CronTask) DelTask(id int) error

/add a task

func (*CronTask) StartTask

func (cm *CronTask) StartTask() error

/start the cron

func (*CronTask) StopTask

func (cm *CronTask) StopTask() error

/stop the task

type CronTaskJob

type CronTaskJob struct {
	Time    string
	TaskId  string
	WorkFun func(s string)
	RunId   int
}

/define the job

func NewJob

func NewJob(time string, fun func(s string), data interface{}) *CronTaskJob

func (*CronTaskJob) Run

func (ct *CronTaskJob) Run()

/define the task

type CronTimeTaskJob

type CronTimeTaskJob struct {
	CronDataTaskJob
	// contains filtered or unexported fields
}

/define data job

func NewTimeJob

func NewTimeJob(time time.Time, workFun func(s string, data interface{}), data interface{}) *CronTimeTaskJob

func (*CronTimeTaskJob) Run

func (ct *CronTimeTaskJob) Run()

/define the task