task

Documentation

Index

• type Factory
  • func GlobalFactory() *Factory
  • func New(repo Repo) *Factory
  • func (t *Factory) AddCron(id uint32, spec string) error
  • func (t *Factory) Close()
  • func (t *Factory) DrySpec(s string) bool
  • func (t *Factory) RemoveCron(id uint32) error
  • func (t *Factory) Scheduler(id uint32) error
  • func (t *Factory) UpdateCron(id uint32, spec string) error
• type Repo

Types

type Factory

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

func GlobalFactory

func GlobalFactory() *Factory

func New

func New(repo Repo) *Factory

func (*Factory) AddCron

func (t *Factory) AddCron(id uint32, spec string) error

func (*Factory) Close

func (t *Factory) Close()

func (*Factory) DrySpec

func (t *Factory) DrySpec(s string) bool

func (*Factory) RemoveCron

func (t *Factory) RemoveCron(id uint32) error

func (*Factory) Scheduler

func (t *Factory) Scheduler(id uint32) error

func (*Factory) UpdateCron

func (t *Factory) UpdateCron(id uint32, spec string) error

type Repo

type Repo interface {
	biz.WorkerRepo
	biz.TaskRepo
	biz.LogRepo
}