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 module

Go to main page

Versions in this module

v2

v2.1.2

Jan 18, 2026

Changes in this version

type Queue

+ func (q *Queue) ClearFailedJobs() error

+ func (q *Queue) GetFailedJob(jobId string) (string, error)

+ func (q *Queue) GetFailedJobs() ([]Job, error)

v2.1.1

Oct 21, 2025

Changes in this version

type Job

+ func (job *Job) HandlerError(reasonError string)

+ type Logger interface

+ Errorf func(msg string, metadata ...any)

+ Fatalf func(msg string, metadata ...any)

+ Infof func(msg string, metadata ...any)

+ Warnf func(msg string, metadata ...any)

type LoggerType

+ const LoggerError

+ const LoggerWarn

type Options

+ DisableLog bool

+ Prefix string

type Queue

+ Logger Logger

v2.1.0

Jun 8, 2025

Changes in this version

+ func ForRootFactory(factory func(ref core.RefProvider) *Options) core.Modules

type Options

+ Timeout time.Duration

+ type Processor struct

+ func NewProcessor(name string, module core.Module) *Processor

+ func (p *Processor) Process(jobFnc JobFnc)

type Queue

+ func (q *Queue) MarkJobFailedTimeout(numberJobs []*Job)

v2.0.1

Apr 13, 2025

Changes in this version

+ func ForRoot(opt *Options) core.Modules

+ func Remove[T any](slice []T, removeIf func(T) bool) []T

+ type LoggerType string

+ const LoggerDefault

+ const LoggerDisabled

+ const LoggerFatal

+ const LoggerInfo

+ const LoggerPanic

type Options

+ Delay time.Duration

+ Logger LoggerType

+ RemoveOnComplete bool

+ RemoveOnFail bool

type Queue

+ func (q *Queue) RemoveCompleted()

+ func (q *Queue) RemoveFailed()

v2.0.0

Mar 23, 2025

Changes in this version

+ const QUEUE

+ func Min(a int, b int) int

+ func Register(name string, opt *Options) core.Modules

+ type AddJobOptions struct

+ Data interface{}

+ Id string

+ Priority int

+ type Callback func() error

+ type Job struct

+ Data interface{}

+ FailedReason string

+ FinishedOn time.Time

+ Id string

+ Priority int

+ ProcessedOn time.Time

+ RetryFailures int

+ Stacktrace []string

+ Status JobStatus

+ func (job *Job) IsFinished() bool

+ func (job *Job) IsReady() bool

+ func (job *Job) Process(cb Callback)

+ type JobFnc func(job *Job)

+ type JobStatus string

+ const ActiveStatus

+ const CompletedStatus

+ const DelayedStatus

+ const FailedStatus

+ const WaitStatus

+ type Options struct

+ Connect *redis.Options

+ Limiter *RateLimiter

+ Pattern string

+ RetryFailures int

+ Workers int

+ type Queue struct

+ Name string

+ RetryFailures int

+ func Inject(module core.Module, name string) *Queue

+ func New(name string, opt *Options) *Queue

+ func (q *Queue) AddJob(opt AddJobOptions)

+ func (q *Queue) BulkAddJob(options []AddJobOptions)

+ func (q *Queue) CountJobs(status JobStatus) int

+ func (q *Queue) IsLimit() bool

+ func (q *Queue) Pause()

+ func (q *Queue) Process(jobFnc JobFnc)

+ func (q *Queue) Remove(key string)

+ func (q *Queue) Resume()

+ func (q *Queue) Retry()

+ func (q *Queue) Run()

+ type RateLimiter struct

+ Duration time.Duration

+ Max int

Other modules containing this package

github.com/tinh-tinh/queue