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
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

queue

package

Go to main page

Versions in this module

v0

v0.11.1

May 18, 2026

v0.11.0

Apr 16, 2026

v0.10.0

Apr 16, 2026

v0.9.2

Apr 11, 2026

v0.9.1

Apr 9, 2026

v0.9.0

Apr 8, 2026

Changes in this version

+ const DefaultAppName

+ const DefaultMaxRetries

+ const DefaultNamespace

+ const DefaultPollInterval

+ const DefaultShutdownTimeout

+ const DefaultVisibilityTimeout

+ var ErrSkipRetry = errors.New("queue: skip retry")

+ func DeadLetterTopic(formattedTopic string) string

+ func DefaultBackoff(attempt int) time.Duration

+ func FormatTopic(app, namespace, topic string) string

+ func ResolveSubscribeConfig(cfg *SubscribeConfig, formattedTopic string)

+ func SkipRetry(err error) error

+ type BackoffFunc func(attempt int) time.Duration

+ type Clock interface

+ NewTimer func(d time.Duration) Timer

+ Now func() time.Time

+ func RealClock() Clock

+ type Consumer interface

+ Close func() error

+ type EnqueueConfig struct

+ App string

+ Namespace string

+ Priority Priority

+ RunAt time.Time

+ type EnqueueOption interface

+ Apply func(*EnqueueConfig)

+ func WithDelay(d time.Duration) EnqueueOption

+ func WithEnqueueApp(app string) EnqueueOption

+ func WithEnqueueNamespace(ns string) EnqueueOption

+ func WithPriority(p Priority) EnqueueOption

+ func WithRunAt(t time.Time) EnqueueOption

+ type EnqueueOptionFunc func(*EnqueueConfig)

+ func (f EnqueueOptionFunc) Apply(cfg *EnqueueConfig)

+ type Enqueuer interface

+ Enqueue func(ctx context.Context, topic string, payload []byte, opts ...EnqueueOption) error

+ type Handler func(ctx context.Context, job *Job) error

+ type Job struct

+ Attempt int

+ EnqueuedAt time.Time

+ ID string

+ Payload []byte

+ Topic string

+ type Priority int8

+ const PriorityHigh

+ const PriorityLow

+ const PriorityNormal

+ type QueueConfig struct

+ App string

+ Namespace string

+ type QueueOption interface

+ Apply func(*QueueConfig)

+ func WithApp(app string) QueueOption

+ func WithNamespace(ns string) QueueOption

+ type QueueOptionFunc func(*QueueConfig)

+ func (f QueueOptionFunc) Apply(cfg *QueueConfig)

+ type Service interface

+ Close func(ctx context.Context) error

+ type SubscribeConfig struct

+ App string

+ Backoff BackoffFunc

+ Concurrency int

+ DeadLetterTopic string

+ MaxRetries int

+ Namespace string

+ PollInterval time.Duration

+ ShutdownTimeout time.Duration

+ VisibilityTimeout time.Duration

+ type SubscribeOption interface

+ Apply func(*SubscribeConfig)

+ func WithBackoff(b BackoffFunc) SubscribeOption

+ func WithConcurrency(n int) SubscribeOption

+ func WithDeadLetterTopic(topic string) SubscribeOption

+ func WithMaxRetries(n int) SubscribeOption

+ func WithPollInterval(d time.Duration) SubscribeOption

+ func WithShutdownTimeout(d time.Duration) SubscribeOption

+ func WithSubscribeApp(app string) SubscribeOption

+ func WithSubscribeNamespace(ns string) SubscribeOption

+ func WithVisibilityTimeout(d time.Duration) SubscribeOption

+ type SubscribeOptionFunc func(*SubscribeConfig)

+ func (f SubscribeOptionFunc) Apply(cfg *SubscribeConfig)

+ type Subscriber interface

+ Subscribe func(ctx context.Context, topic string, h Handler, opts ...SubscribeOption) (Consumer, error)

+ type Timer interface

+ C func() <-chan time.Time

+ Reset func(d time.Duration) bool

+ Stop func() bool