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

taskq

package module

Go to main page

Versions in this module

v1

v1.1.0

Sep 15, 2026

Changes in this version

+ const SettleOpAck

+ const SettleOpNack

type PoolOption

+ func WithOnDecodeError(fn func(ctx context.Context, msg Message, err error)) PoolOption

+ func WithOnSettleError(fn func(ctx context.Context, op string, msg Message, err error)) PoolOption

+ func WithSettleTimeout(d time.Duration) PoolOption

v1.0.1

Sep 11, 2026

v1.0.0

Sep 6, 2026

Changes in this version

+ var ErrQueueClosed = errors.New("taskQ: queue closed")

+ type BackoffStrategy interface

+ Next func(attempt int) time.Duration

+ type Broker interface

+ Ack func(ctx context.Context, msg Message) error

+ Dequeue func(ctx context.Context, queue string) (*Message, error)

+ Enqueue func(ctx context.Context, msg Message) error

+ Nack func(ctx context.Context, msg Message, cause error) error

+ type ConstantBackoff struct

+ Delay time.Duration

+ func (b ConstantBackoff) Next(attempt int) time.Duration

+ type EnqueueOption func(*enqueueConfig)

+ func WithMaxRetry(n int) EnqueueOption

+ type ExponentialBackoff struct

+ Base time.Duration

+ Factor float64

+ Jitter bool

+ Max time.Duration

+ func (b ExponentialBackoff) Next(attempt int) time.Duration

+ type Handler func(ctx context.Context, task Task[T]) error

+ func Chain[T any](h Handler[T], mws ...Middleware[T]) Handler[T]

+ type Message struct

+ Attempts int

+ EnqueuedAt time.Time

+ ID string

+ MaxRetry int

+ Payload []byte

+ Queue string

+ ReceiptHandle string

+ type Middleware func(Handler[T]) Handler[T]

+ func LoggingMiddleware[T any](logger *slog.Logger) Middleware[T]

+ func RecoveryMiddleware[T any]() Middleware[T]

+ type PanicError struct

+ Value any

+ func (e *PanicError) Error() string

+ func (e *PanicError) Stack() []byte

+ type Pool struct

+ func NewPool[T any](broker Broker, queue string, handler Handler[T], opts ...PoolOption) *Pool[T]

+ func (p *Pool[T]) Run(ctx context.Context) error

+ type PoolOption func(*poolConfig)

+ func WithBackoffStrategy(s BackoffStrategy) PoolOption

+ func WithConcurrency(n int) PoolOption

+ type Queue struct

+ func NewQueue[T any](broker Broker, name string, opts ...QueueOption) *Queue[T]

+ func (q *Queue[T]) Enqueue(ctx context.Context, payload T, opts ...EnqueueOption) error

+ type QueueOption func(*queueConfig)

+ func WithDefaultMaxRetry(n int) QueueOption

+ type Task struct

+ Attempts int

+ EnqueuedAt time.Time

+ ID string

+ MaxRetry int

+ Payload T

+ Queue string