task

Documentation

Index

• func Test()
• type Factory
  • func (e *Factory) Create() (res Task)
• type Proxy
  • func (p *Proxy) Add(options map[string]interface{}) (err error)
  • func (p *Proxy) GetTaskId() (taskId string)
  • func (p *Proxy) Init(tenantId consts.TenantId, source consts.CronSource, ...)
  • func (p *Proxy) Remove()
  • func (p Proxy) Run(options map[string]interface{})
• type Task

Functions

func Test

func Test()

Types

type Factory

type Factory struct {
	SwaggerCron       *service.SwaggerCron       `inject:""`
	LecangCronService *service.LecangCronService `inject:""`
	// contains filtered or unexported fields
}

func (*Factory) Create

func (e *Factory) Create() (res Task)

type Proxy

type Proxy struct {
	ServerCron         *cron.ServerCron            `inject:""`
	Factory            *Factory                    `inject:""`
	ProjectCronService *service.ProjectCronService `inject:""`
	// contains filtered or unexported fields
}

func (*Proxy) Add

func (p *Proxy) Add(options map[string]interface{}) (err error)

func (*Proxy) GetTaskId

func (p *Proxy) GetTaskId() (taskId string)

func (*Proxy) Init

func (p *Proxy) Init(tenantId consts.TenantId, source consts.CronSource, beforeCall func(tenantId consts.TenantId, taskId string, source consts.CronSource) error, callBack func(tenantId consts.TenantId, taskId string, source consts.CronSource, err error) error, taskId, cron string)

func (*Proxy) Remove

func (p *Proxy) Remove()

func (Proxy) Run

func (p Proxy) Run(options map[string]interface{})

type Task

type Task interface {
	Run(options map[string]interface{}) (f func() error)
	CallBack(options map[string]interface{}, err error) func()
}