timer

Documentation

Index

• type TaskFunc
• type Timer
  • func New(l log.Logger, taskInterval, taskDelay time.Duration) Timer

Types

type TaskFunc

type TaskFunc func() (hasMore bool, err error)

TaskFunc only task function can be added to the timer.

type Timer

type Timer interface {
	AddTask(taskFunc TaskFunc)
	Run()
	Close()
}

Timer is for processing task. it checks buckets for popping jobs. it will put ready jobs to queue.

func New

func New(l log.Logger, taskInterval, taskDelay time.Duration) Timer

New create a new timer for loading ready jobs from bucket