bg

Dec 1, 2019

Changes in this version

+ var ErrDrain = errors.New("registry is draining")

+ var ErrDup = errors.New("job has already been registered")

+ func BG(parent context.Context, f func(ctx context.Context)) error

+ func Dispatch(ctx context.Context, j Job) error

+ func RegWithContext(ctx context.Context, r *Reg) context.Context

+ type Job interface

+ Start func()

+ Stop func()

+ type Reg struct

+ func NewReg(service string, ctx context.Context) *Reg

+ func RegFromContext(ctx context.Context) *Reg

+ func (r *Reg) Dispatch(j Job) error

+ func (r *Reg) Drain()

+ type Task struct

+ func NewTask(f func()) *Task

+ func (t *Task) Start()

+ func (t *Task) Stop()