worker

Documentation

Index

• type FuncWorker
  • func (f *FuncWorker) After(ctl *controller.TaskCtl, funcArgs []string, result *message.Result) error
  • func (f *FuncWorker) Run(ctl *controller.TaskCtl, funcArgs []string, result *message.Result) error
  • func (f *FuncWorker) WorkerName() string
• type WorkerInterface

Types

type FuncWorker

type FuncWorker struct {
	Func         interface{} // 执行的函数
	CallbackFunc interface{} // 回调函数
	Name         string
	Logger       log.LoggerInterface
}

func (*FuncWorker) After

func (f *FuncWorker) After(ctl *controller.TaskCtl, funcArgs []string, result *message.Result) error

func (*FuncWorker) Run

func (f *FuncWorker) Run(ctl *controller.TaskCtl, funcArgs []string, result *message.Result) error

func (*FuncWorker) WorkerName

func (f *FuncWorker) WorkerName() string

type WorkerInterface

type WorkerInterface interface {
	Run(ctl *controller.TaskCtl, funcArgs []string, result *message.Result) error
	WorkerName() string
	After(ctl *controller.TaskCtl, funcArgs []string, result *message.Result) error
}