worker

Aug 12, 2017

Changes in this version

type Args

+ func (a Args) String() string

type Job

+ func (j Job) String() string

+ type Simple struct

+ Logger SimpleLogger

+ func (w *Simple) Register(name string, h Handler) error

+ func (w *Simple) Start(ctx context.Context) error

+ func (w Simple) Perform(job Job) error

+ func (w Simple) PerformAt(job Job, t time.Time) error

+ func (w Simple) PerformIn(job Job, d time.Duration) error

+ func (w Simple) Stop() error

+ type SimpleLogger interface

+ Debug func(...interface{})

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

+ Error func(...interface{})

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

+ Info func(...interface{})

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

Jun 19, 2017

Changes in this version

+ type Args map[string]interface

+ type Handler func(Args) error

+ type Job struct

+ Args Args

+ Handler string

+ Queue string

+ type Worker interface

+ Perform func(Job) error

+ PerformAt func(Job, time.Time) error

+ PerformIn func(Job, time.Duration) error

+ Register func(string, Handler) error

+ Start func(context.Context) error

+ Stop func() error

+ func NewSimple() Worker

+ func NewSimpleWithContext(ctx context.Context) Worker