workers

package module

Go to main page

Versions in this module

v1

v1.2.4

Nov 23, 2021

v1.2.3

Aug 26, 2021

v1.2.2

Aug 23, 2021

v1.2.1

Aug 23, 2021

Changes in this version

+ const MetricsNamespace

+ var TaskDequeueMetric = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var TaskEnqueueMetric = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var TaskProcessedMetric = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ func MetricsHandler() http.Handler

v1.2.0

Jul 12, 2021

v1.1.3

Jun 8, 2021

Changes in this version

+ var TaskDequeue = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var TaskEnqueue = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var TaskFailed = prometheus.NewCounter(prometheus.CounterOpts{ ... })

+ var TaskProcessed = prometheus.NewCounter(prometheus.CounterOpts{ ... })

+ var TaskRetries = prometheus.NewCounter(prometheus.CounterOpts{ ... })

+ func MetricsServer(port int)

v1.1.2

Jan 5, 2021

Changes in this version

type EnqueueOptions

+ Policy int

v1.1.1

Jan 12, 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 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

+ Retry bool

+ RetryCount int

+ 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 WorkersLogger interface

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

+ Println func(...interface{})

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL