Documentation ¶ Index ¶ func AddQueue(ctx context.Context, f func(context.Context) error, errMsg string) func SetQueueSize(queueSize int) func StartConsumerPool(ctx context.Context, queueSize, consumerSize, taskMaxRetryCnt int, ...) Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ func AddQueue ¶ func AddQueue(ctx context.Context, f func(context.Context) error, errMsg string) func SetQueueSize ¶ added in v2.1.40 func SetQueueSize(queueSize int) func StartConsumerPool ¶ added in v2.1.18 func StartConsumerPool(ctx context.Context, queueSize, consumerSize, taskMaxRetryCnt int, goFunc func(f func() error)) Types ¶ This section is empty. Source Files ¶ View all Source files async.go Click to show internal directories. Click to hide internal directories.