task

type Handlers struct {
	Exec     func(int, ...interface{}) (interface{}, error)
	Progress func(int, int, int, string)
	NextID   func() (int, error)
	Add      func(int)
	Success  func(int, interface{})
	Error    func(int, error)
}

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

type Option struct {
	Name           string
	JobQueueLength int
	WorkerNums     int
	AttemptAfter   int
	Attempts       int
	Timeout        int
}

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

type ProcessOption struct {
	Name         string      `json:"name"`
	Process      string      `json:"process"`
	Size         interface{} `json:"size,omitempty"`
	WorkerNums   interface{} `json:"worker_nums,omitempty"`
	AttemptAfter interface{} `json:"attempt_after,omitempty"`
	Attempts     interface{} `json:"attempts,omitempty"`
	Timeout      interface{} `json:"timeout,omitempty"`
	Event        struct {
		Next     string `json:"next,omitempty"`
		Add      string `json:"add,omitempty"`
		Success  string `json:"success,omitempty"`
		Error    string `json:"error,omitempty"`
		Progress string `json:"progress,omitempty"`
	} `json:"event"`
}

type Task struct {
	Option Option
	// contains filtered or unexported fields
}

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