Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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

workers

package module

Go to main page

Versions in this module

v1

v1.0.101

Jul 12, 2022

v1.0.1

Aug 21, 2019

v1.0.0

Feb 27, 2019

Changes in this version

+ func SetLogger(l WorkersLogger)

type WorkersLogger

+ Debug func(args ...interface{})

+ Debugf func(format string, args ...interface{})

+ Debugln func(args ...interface{})

+ Error func(args ...interface{})

+ Errorf func(format string, args ...interface{})

+ Errorln func(args ...interface{})

+ Fatal func(format ...interface{})

+ Fatalf func(format string, args ...interface{})

+ Fatalln func(args ...interface{})

+ Info func(args ...interface{})

+ Infof func(format string, args ...interface{})

+ Infoln func(args ...interface{})

+ Warn func(args ...interface{})

+ Warnf func(format string, args ...interface{})

+ Warnln func(args ...interface{})

v0

v0.0.2

Feb 14, 2019

v0.0.1

Oct 4, 2018

Changes in this version

+ const DEFAULT_MAX_RETRY

+ const LAYOUT

+ const NanoSecondPrecision

+ const RETRY_KEY

+ const SCHEDULED_JOBS_KEY

+ var Config *config

+ var Middleware = NewMiddleware(&MiddlewareLogging{}, &MiddlewareRetry{}, &MiddlewareStats{})

+ func BeforeStart(f func())

+ func Configure(options map[string]string)

+ func DuringDrain(f func())

+ func Enqueue(queue, class string, args interface{}) (string, error)

+ func EnqueueAt(queue, class string, at time.Time, args interface{}) (string, error)

+ func EnqueueIn(queue, class string, in float64, args interface{}) (string, error)

+ func EnqueueWithOptions(queue, class string, args interface{}, opts EnqueueOptions) (string, error)

+ func GetConnectionPool(options map[string]string) *redis.Pool

+ func Process(queue string, job jobFunc, concurrency int, mids ...Action)

+ func Quit()

+ func ResetManagers() error

+ func Run()

+ func Start()

+ func Stats(w http.ResponseWriter, req *http.Request)

+ func StatsServer(port int)

+ type Action interface

+ Call func(queue string, message *Msg, next func() bool) bool

+ type Args struct

+ func (d Args) Equals(other interface{}) bool

+ func (d Args) ToJson() string

+ type EnqueueData struct

+ Args interface{}

+ Class string

+ EnqueuedAt float64

+ Jid string

+ Queue string

+ type EnqueueOptions struct

+ At float64

+ ConnectionOptions map[string]string

+ Retry bool

+ RetryCount int

+ RetryMax int

+ RetryOptions RetryOptions

+ type Fetcher interface

+ Acknowledge func(*Msg)

+ Close func()

+ Closed func() bool

+ Fetch func()

+ FinishedWork func() chan bool

+ Messages func() chan *Msg

+ Queue func() string

+ Ready func() chan bool

+ func NewFetch(queue string, messages chan *Msg, ready chan bool) Fetcher

+ type MiddlewareLogging struct

+ func (l *MiddlewareLogging) Call(queue string, message *Msg, next func() bool) (acknowledge bool)

+ type MiddlewareRetry struct

+ func (r *MiddlewareRetry) Call(queue string, message *Msg, next func() bool) (acknowledge bool)

+ type MiddlewareStats struct

+ func (l *MiddlewareStats) Call(queue string, message *Msg, next func() bool) (acknowledge bool)

+ type Middlewares struct

+ func NewMiddleware(actions ...Action) *Middlewares

+ func (m *Middlewares) Append(action Action)

+ func (m *Middlewares) Prepend(action Action)

+ type Msg struct

+ func NewMsg(content string) (*Msg, error)

+ func (d Msg) Equals(other interface{}) bool

+ func (d Msg) ToJson() string

+ func (m *Msg) Args() *Args

+ func (m *Msg) Jid() string

+ func (m *Msg) OriginalJson() string

+ type RetryOptions struct

+ Exp int

+ MaxDelay int

+ MaxRand int

+ MinDelay int

+ type WorkerStats struct

+ Enqueued map[string]string

+ Failed int

+ Processed int

+ Retries int64

+ func GetStats() *WorkerStats

+ type WorkersLogger interface

+ Printf func(string, ...interface{})

+ Println func(...interface{})

+ var Logger WorkersLogger = log.New(os.Stdout, "workers: ", log.Ldate | log.Lmicroseconds)