task

Documentation

Index

• Constants
• type Factory
  • func GlobalFactory() *Factory
  • func Init(repo *Repo) *Factory
  • func (t *Factory) AddCron(id uint32, spec string) error
  • func (t *Factory) CancelExec(ctx kratosx.Context, uuid 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, force bool) error
  • func (t *Factory) UpdateCron(id uint32, spec string) error
• type Repo

Constants

const (
	ExecTypeGroup = "group"
)

Types

type Factory

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

func GlobalFactory

func GlobalFactory() *Factory

func Init

func Init(repo *Repo) *Factory

func (*Factory) AddCron

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

func (*Factory) CancelExec

func (t *Factory) CancelExec(ctx kratosx.Context, uuid 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, force bool) error

func (*Factory) UpdateCron

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

type Repo

type Repo struct {
	Task   task.Repo
	Log    log.Repo
	Worker worker.Repo
}