work

package

v1.4.12 Latest Latest Go to latest Published: Apr 24, 2020 License: Apache-2.0 Imports: 4 Imported by: 0

Details

@Time : 2019-12-09 09:20 @Author : zr

This section is empty.

This section is empty.

This section is empty.

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

IntervalWork 间隔时间任务

func RegisterNewWork(intervalTime time.Duration, loopFunc LoopFunc, onError OnError) *IntervalWork

func (w *IntervalWork) Join()

func (i *IntervalWork) Run()

func (w *IntervalWork) Stop()

type LoopFunc func(ctx context.Context) (err error)

type OnError func(err error)

type ScheduleDayWork struct {
	ScheduleTime time.Time
	// contains filtered or unexported fields
}

ScheduleWork 每日固定时间任务

func RegisterScheduleDayWork(schedule time.Time, loopFunc LoopFunc, onError OnError) *ScheduleDayWork

func (w *ScheduleDayWork) Join()

func (s *ScheduleDayWork) Run()

func (w *ScheduleDayWork) Stop()

type Work interface {
	Run()
	Stop()
	Join()
	// contains filtered or unexported methods
}