Documentation
¶
Index ¶
- Variables
- func ExecCommand(classify string, scriptPath string, params string) (err error)
- func NewAsyncTaskWorker(concurrency int) *machinery.Worker
- func NewTaskCenter() (*machinery.Server, error)
- func SendTask(ctx context.Context, classify string, scriptPath string, params string)
- func StartServer()
Constants ¶
This section is empty.
Variables ¶
View Source
var AsyncTaskCenter *machinery.Server
Functions ¶
func ExecCommand ¶
ExecCommand 异步任务
func NewAsyncTaskWorker ¶
func NewAsyncTaskWorker(concurrency int) *machinery.Worker
func NewTaskCenter ¶
func NewTaskCenter() (*machinery.Server, error)
func StartServer ¶
func StartServer()
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.