workers

package

v1.5.1 Latest Latest Go to latest Published: Jan 29, 2018 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

View Source

var (
	ErrAlreadyWorker = errors.New("worker name must be unique")
	ErrWrongOptions  = errors.New("wrong options")
)

func New(opts Options) (err error)

func Start()

func Stop()

func Wait()

type Options struct {
	Name     string
	Schedule Schedule
	Handler  func()
}

type Schedule interface {
	cron.Schedule
}

func Every(duration time.Duration) Schedule

func Parse(spec string) (Schedule, error)