ctxerrgroup

Dec 1, 2020

Changes in this version

+ var ErrCantDo = errors.New("failed to send work item to a worker before the context expired")

+ type ErrorHandler func(group Group, err error)

+ type Group struct

+ func New(workers uint, workItemBuffer uint, asyncErrors bool, errorHandler ErrorHandler) Group

+ func (g Group) AddWorkItem(ctx context.Context, cancel context.CancelFunc, work Work)

+ func (g Group) Dead() bool

+ func (g Group) Death() <-chan struct{}

+ func (g Group) Done() <-chan struct{}

+ func (g Group) Kill()

+ func (g Group) Wait()

+ type Work func(workCtx context.Context) (err error)