worker

Documentation

Index

• Constants
• Variables
• func HelloWorld() error
• func NewAsyncTaskWorker(concurrency int) *machinery.Worker
• func NewTaskCenter() (*machinery.Server, error)
• func SendHelloWorldTask(ctx context.Context)

Constants

const (
	HelloWorldTaskName          = "HelloWorldTask"
	DeleteAppShareImageTaskName = "DeleteAppShareImageTask"
)

方法名

Variables

var (
	AsyncTaskCenter *machinery.Server
)

Functions

func HelloWorld

func HelloWorld() error

HelloWorld 测试异步任务

func NewAsyncTaskWorker

func NewAsyncTaskWorker(concurrency int) *machinery.Worker

func NewTaskCenter

func NewTaskCenter() (*machinery.Server, error)

GID_TEST,test_topic,Your Access Key,Your Secret Key,ALIYUN

func SendHelloWorldTask

func SendHelloWorldTask(ctx context.Context)

SendHelloWorldTask 调用点调用此异步任务函数