timerjob

Documentation

Index

• type BaseTimerJob
  • func (j *BaseTimerJob) Run()
  • func (j *BaseTimerJob) Stop()
• type RedisLockerJob
  • func (j *RedisLockerJob) Run()
  • func (j *RedisLockerJob) Stop()
• type TimerJob
• type TimerJobList
  • func (l *TimerJobList) AddJob(job ...TimerJob)
  • func (l *TimerJobList) Start()
  • func (l *TimerJobList) Stop()

Types

type BaseTimerJob

type BaseTimerJob struct {
	Interval time.Duration
	Worker   func()
	// contains filtered or unexported fields
}

func (*BaseTimerJob) Run

func (j *BaseTimerJob) Run()

func (*BaseTimerJob) Stop

func (j *BaseTimerJob) Stop()

type RedisLockerJob

type RedisLockerJob struct {
	BaseTimerJob

	Redis      *redis.Client
	LockID     string
	LockExpire time.Duration
}

func (*RedisLockerJob) Run

func (j *RedisLockerJob) Run()

func (*RedisLockerJob) Stop

func (j *RedisLockerJob) Stop()

type TimerJob

type TimerJob interface {
	Run()
	Stop()
}

type TimerJobList

type TimerJobList struct {
	sync.WaitGroup
	Jobs []TimerJob
}

func (*TimerJobList) AddJob

func (l *TimerJobList) AddJob(job ...TimerJob)

func (*TimerJobList) Start

func (l *TimerJobList) Start()

func (*TimerJobList) Stop

func (l *TimerJobList) Stop()