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

workers

package module

Go to main page

Versions in this module

v0

v0.1.2

Jul 13, 2022

Changes in this version

+ var ErrJidExists = fmt.Errorf("jid has already exists")

type EnqueueOptFunc

+ func WithJid(jid string) EnqueueOptFunc

type EnqueueParam

+ Jid string

v0.1.1

Jun 30, 2022

Changes in this version

+ const CANCEL_KEY

+ func CancelJob(jid string) error

type Fetcher

+ Continue func(*Msg) bool

v0.1.0

Mar 29, 2022

Changes in this version

+ const ARGV_VALUE_KEY

+ const DEFAULT_MAX_RETRIES

+ const INPROGRESS_JOBS_KEY

+ const LAYOUT

+ const NanoSecondPrecision

+ const RETRY_KEY

+ const SCHEDULED_JOBS_KEY

+ var Config *config

+ var Logger = logrus.WithField("from", "go-workers")

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

+ func BeforeStart(f func())

+ func Configure(options map[string]interface{})

+ func DuringDrain(f func())

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

+ func JobExists(jid string) (bool, error)

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

+ func Quit()

+ func ResetManagers() error

+ func Run()

+ func ShouldRetry(message *Msg) bool

+ func Start()

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

+ func StatsServer(port int)

+ type Acknowledge struct

+ KeepData bool

+ type Action interface

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

+ type Args struct

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

+ func (d Args) ToJson() string

+ type CallResult struct

+ Acknowledge bool

+ Err error

+ KeepValue bool

+ type EnqueueData struct

+ Args interface{}

+ Class string

+ EnqueuedAt float64

+ Jid string

+ Queue string

+ type EnqueueOptFunc func(param *EnqueueParam)

+ func WithAt(at time.Time) EnqueueOptFunc

+ func WithIn(in time.Duration) EnqueueOptFunc

+ func WithMaxRetries(maxRetries int) EnqueueOptFunc

+ func WithRetry() EnqueueOptFunc

+ func (e EnqueueOptFunc) Apply(param *EnqueueParam)

+ type EnqueueOptions interface

+ Apply func(param *EnqueueParam)

+ type EnqueueParam struct

+ At float64

+ MaxRetries int

+ RetryCount int

+ type Fetcher interface

+ Acknowledge func(*Acknowledge)

+ Close func()

+ Closed func() bool

+ Fetch func()

+ FinishedWork func() chan bool

+ Heartbeat func(*Msg)

+ HeartbeatJob func(*Msg) 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() CallResult) (result CallResult)

+ type MiddlewareRetry struct

+ func (r *MiddlewareRetry) Call(queue string, message *Msg, next func() CallResult) (result CallResult)

+ type MiddlewareStats struct

+ func (l *MiddlewareStats) Call(queue string, message *Msg, next func() CallResult) (result CallResult)

+ type Middlewares struct

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

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

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

+ type Msg struct

+ Context map[string]interface{}

+ Logger *logrus.Entry

+ 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

+ func (s *Msg) Args2Obj(obj interface{}) error