worker

Documentation

Index

• type FuncWorker
  • 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 {
	F    interface{}
	Name string
}

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
}