Help us shape the future of Go! Take the 2026 Go Developer Survey

Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

taskqueue

package

Go to main page

Versions in this module

v1

v1.21.2

Oct 27, 2026

v1.21.1

Oct 25, 2026

v1.21.0

Sep 29, 2026

Changes in this version

+ const BatchEmailTaskTimeout

v1.20.3

Sep 19, 2026

Changes in this version

+ const DeferCloseOrder

+ const EmailTypeCustom

+ const EmailTypeExpiration

+ const EmailTypeMaintenance

+ const EmailTypeTrafficExceed

+ const EmailTypeVerify

+ const EventDeliver

+ const ForthwithActivateOrder

+ const ForthwithQuotaTask

+ const ForthwithSendEmail

+ const ForthwithSendSms

+ const ForthwithTrafficStatistics

+ const ScheduledBatchSendEmail

+ const SchedulerCheckSubscription

+ const SchedulerCleanupOrderEvents

+ const SchedulerDailyOrderReport

+ const SchedulerDispatchDomainEvents

+ const SchedulerExchangeRate

+ const SchedulerFlushTraffic

+ const SchedulerLogCleanup

+ const SchedulerPublishOrderEvents

+ const SchedulerReconcilePaidOrders

+ const SchedulerReconcilePendingOrders

+ const SchedulerRemindExpiringSubscriptions

+ const SchedulerResetTraffic

+ const SchedulerTotalServerData

+ const SchedulerTrafficStat

+ func ActivationTaskID(orderNo string) string

+ func EventTaskID(id int64) string

+ func Middleware() asynq.MiddlewareFunc

+ func Wrap(ctx context.Context, task *asynq.Task) *asynq.Task

+ type Client struct

+ func NewClient(client *asynq.Client) *Client

+ func (c *Client) EnqueueContext(ctx context.Context, task *asynq.Task, opts ...asynq.Option) (*asynq.TaskInfo, error)

+ type DeferCloseOrderPayload struct

+ OrderNo string

+ type EventDeliverPayload struct

+ ID int64

+ Key string

+ Payload string

+ Topic string

+ type ForthwithActivateOrderPayload struct

+ OrderNo string

+ type NodeStatus struct

+ LastAt int64

+ OnlineUsers []OnlineUser

+ Status ServerStatus

+ type OnlineUser struct

+ IP string

+ UID int64

+ type SendEmailPayload struct

+ Content map[string]interface{}

+ Email string

+ Subject string

+ Type string

+ type SendSmsPayload struct

+ Content string

+ Telephone string

+ TelephoneArea string

+ Type uint8

+ type ServerStatus struct

+ Cpu float64

+ Disk float64

+ Mem float64

+ UpdatedAt int64

+ type ServerTrafficCount struct

+ Name string

+ ServerId int64

+ Today int64

+ Yesterday int64

+ type TrafficStatistics struct

+ Logs []UserTraffic

+ Protocol string

+ ServerId int64

+ type UserTraffic struct

+ Download int64

+ SID int64

+ Upload int64