Versions in this module Expand all Collapse all v0 v0.0.5 Sep 5, 2023 v0.0.4 Aug 24, 2023 Changes in this version + func NewExecutor(ctx context.Context, options ...Option) (err error) + type Executor interface + AddRegTask func(handler string, task FuncTask) + GetTaskInstance func() common2.RunReq + RegTask func() (err error) + Run func() (err error) + RunTask func(req common2.RunReq) common2.CallElement + func GetExecutor() Executor + type FuncTask func(param common2.RunReq) (code int, msg string) + type ListTask struct + func (t *ListTask) Del(key string) + func (t *ListTask) Exists(key string) bool + func (t *ListTask) Get(key string) *Task + func (t *ListTask) GetAll() map[string]*Task + func (t *ListTask) GetKeys() []string + func (t *ListTask) Len() int + func (t *ListTask) Set(key string, val *Task) + type Option func(e *executor) + func WithCancelReg(cancel bool) Option + func WithClientId(clientId string) Option + func WithDelay(delay int) Option + func WithHost(host string) Option + func WithTask(handler string, task FuncTask) Option + type Task struct + EndTime int64 + Id string + Name string + Param common2.RunReq + StartTime int64 + func (t *Task) Info() string + func (t *Task) Run() common2.CallElement
Go to main page