Documentation ¶ Index ¶ func AddQueue(ctx context.Context, f func(context.Context) error, errMsg string) func Consumer(ctx context.Context) error func Init(queueSize int) func StartConsumerPool(ctx context.Context, consumerCount int, goFunc func(f func() error)) 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 Consumer ¶ func Consumer(ctx context.Context) error func Init ¶ added in v2.1.18 func Init(queueSize int) func StartConsumerPool ¶ added in v2.1.18 func StartConsumerPool(ctx context.Context, consumerCount 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.