jobs

Documentation

Index

• func AddJob(delay time.Duration, job JobWorker, options ...ItemOption)
• func DelJob(id int64)
• type ItemOption
  • func WithItemDebug(debug bool) ItemOption
  • func WithItemId(id int64) ItemOption
  • func WithItemReplace(replace bool) ItemOption
• type Job
  • func NewJob(worker func(), options ...Option) *Job
  • func (j *Job) BeforeExec()
  • func (j *Job) CanExec() bool
  • func (j *Job) FailNext() (bool, time.Duration)
  • func (j *Job) JobExec() bool
  • func (j *Job) JobFinish()
  • func (j *Job) Name() string
  • func (j *Job) String() string
• type JobItem
  • func NewJobItem(delay time.Duration, worker JobWorker, options ...ItemOption) *JobItem
  • func (s *JobItem) ExecJob()
  • func (s *JobItem) FinishJob()
• type JobKeeper
  • func NewJobKeeper(name string) *JobKeeper
  • func (k *JobKeeper) AddJob(delay time.Duration, job JobWorker, options ...ItemOption)
  • func (k *JobKeeper) DelJob(delId int64)
  • func (k *JobKeeper) ExecJob()
  • func (k *JobKeeper) Stop()
• type JobQueue
  • func NewJobQueue(sTime int64) *JobQueue
  • func (s *JobQueue) AddJob(job *JobItem)
  • func (s *JobQueue) DelJob(delId int64)
  • func (s *JobQueue) ExeJob()
• type JobQueues
  • func (q JobQueues) Len() int
  • func (q JobQueues) Less(i, j int) bool
  • func (q JobQueues) Swap(i, j int)
• type JobWorker
• type Option
  • func WithInterval(interval time.Duration) Option
  • func WithName(name string) Option
  • func WithRepeat(repeat int) Option

Functions

func AddJob

func AddJob(delay time.Duration, job JobWorker, options ...ItemOption)

func DelJob

func DelJob(id int64)

Types

type ItemOption

type ItemOption func(j *JobItem)

func WithItemDebug

func WithItemDebug(debug bool) ItemOption

func WithItemId

func WithItemId(id int64) ItemOption

func WithItemReplace

func WithItemReplace(replace bool) ItemOption

type Job

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

func NewJob

func NewJob(worker func(), options ...Option) *Job

func (*Job) BeforeExec

func (j *Job) BeforeExec()

func (*Job) CanExec

func (j *Job) CanExec() bool

func (*Job) FailNext

func (j *Job) FailNext() (bool, time.Duration)

func (*Job) JobExec

func (j *Job) JobExec() bool

func (*Job) JobFinish

func (j *Job) JobFinish()

func (*Job) Name

func (j *Job) Name() string

func (*Job) String

func (j *Job) String() string

type JobItem

type JobItem struct {
	JobId     int64     //任务标识
	AddTime   int64     //添加时间
	BeginTime int64     //开始时间
	Worker    JobWorker //任务对象
	StartTime int64     //开始时间
	Debug     bool      //是否调试
	Id        string    //任务唯一标识
	Replace   bool      //同jobid是否替换
}

func NewJobItem

func NewJobItem(delay time.Duration, worker JobWorker, options ...ItemOption) *JobItem

func (*JobItem) ExecJob

func (s *JobItem) ExecJob()

func (*JobItem) FinishJob

func (s *JobItem) FinishJob()

type JobKeeper

type JobKeeper struct {
	Name     string
	List     JobQueues
	Index    map[int64]*JobQueue
	AddChan  chan *JobItem
	DelChan  chan int64
	StopChan chan struct{}
	IdList   map[int64]map[int64]int
}

func NewJobKeeper

func NewJobKeeper(name string) *JobKeeper

func (*JobKeeper) AddJob

func (k *JobKeeper) AddJob(delay time.Duration, job JobWorker, options ...ItemOption)

func (*JobKeeper) DelJob

func (k *JobKeeper) DelJob(delId int64)

func (*JobKeeper) ExecJob

func (k *JobKeeper) ExecJob()

func (*JobKeeper) Stop

func (k *JobKeeper) Stop()

type JobQueue

type JobQueue struct {
	StartTime int64     //开始时间
	JobItems  *ds.Queue //任务队列
	// contains filtered or unexported fields
}

func NewJobQueue

func NewJobQueue(sTime int64) *JobQueue

func (*JobQueue) AddJob

func (s *JobQueue) AddJob(job *JobItem)

func (*JobQueue) DelJob

func (s *JobQueue) DelJob(delId int64)

func (*JobQueue) ExeJob

func (s *JobQueue) ExeJob()

type JobQueues

type JobQueues []*JobQueue

func (JobQueues) Len

func (q JobQueues) Len() int

func (JobQueues) Less

func (q JobQueues) Less(i, j int) bool

func (JobQueues) Swap

func (q JobQueues) Swap(i, j int)

type JobWorker

type JobWorker interface {
	String() string                  //任务名称
	BeforeExec()                     //任务执行前操作
	CanExec() bool                   //是否可以执行
	JobExec() bool                   //执行任务,返回执行是否完成
	FailNext() (bool, time.Duration) //失败是否继续执行并且延缓执行时间
	JobFinish()                      //任务执行完成触发
}

type Option

type Option func(j *Job)

func WithInterval

func WithInterval(interval time.Duration) Option

func WithName

func WithName(name string) Option

func WithRepeat

func WithRepeat(repeat int) Option