workers

Documentation

Index

• Variables
• func Log(job *work.Job, next work.NextMiddlewareFunc) error
• func RegisterJob(name string, function func(*work.Job) error)
• type Workers
  • func (w *Workers) Initialize(config *config.Config)
  • func (w *Workers) Shutdown()

Variables

var Config *config.Config

Config ...

var Enqueuer = work.NewEnqueuer(redisNamespace, redisPool)

Enqueuer ...

var Pool *work.WorkerPool

Pool ...

Functions

func Log

func Log(job *work.Job, next work.NextMiddlewareFunc) error

Log ...

func RegisterJob

func RegisterJob(name string, function func(*work.Job) error)

RegisterJob ...

Types

type Workers

type Workers struct{}

Workers ...

func (*Workers) Initialize

func (w *Workers) Initialize(config *config.Config)

Initialize ...

func (*Workers) Shutdown

func (w *Workers) Shutdown()

Shutdown ...