workers

Mar 1, 2021

Changes in this version

type Config

+ StopOnErrors bool

Feb 8, 2021

Changes in this version

type Pool

+ func (p *Pool) Run(ctx context.Context, job Job) error

+ func (p *Pool) RunWithBuilder(ctx context.Context, jobBuilder JobBuilder) error

+ func (p *Pool) StartWithBuilder(jobBuilder JobBuilder) error

Feb 7, 2021

Changes in this version

+ type JobBuilder interface

+ New func() Job

+ type JobBuilderFunc func() Job

+ func (f JobBuilderFunc) New() Job

type Pool

+ func (p *Pool) CloseWithTimeout(timeout time.Duration) error

+ func (p *Pool) StartBuilder(jobBuilder JobBuilder) error

Jan 30, 2021

Changes in this version

type Job

+ func Wrap(job Job, middlewares ...Middleware) Job

Jan 27, 2021

Changes in this version

type Job

+ Do func(ctx context.Context)

+ type JobFunc func(ctx context.Context)

+ func (f JobFunc) Do(ctx context.Context)

+ type Middleware interface

+ Wrap func(job Job) Job

+ type MiddlewareFunc func(job Job) Job

+ func (f MiddlewareFunc) Wrap(job Job) Job

Jan 26, 2021

Changes in this version

+ var ErrInvalidInitial = errors.New("initial workers must match at least the minimum")

+ var ErrInvalidMax = errors.New("maximum workers must be equal or greater than minimum")

+ var ErrInvalidMin = errors.New("minimum workers must be at least one")

+ var ErrMaxReached = errors.New("maximum number of workers reached")

+ var ErrMinReached = errors.New("minimum number of workers reached")

+ var ErrNotConfigured = errors.New("pool not configured")

+ var ErrNotStarted = errors.New("pool has not started")

+ var ErrPoolClosed = errors.New("pool is closed")

+ var ErrPoolStarted = errors.New("pool already started")

+ type Config struct

+ Initial int

+ Max int

+ Min int

+ type Job = func(ctx context.Context)

+ type JobMiddleware = func(job Job) Job

+ type Pool struct

+ func Must(p *Pool, err error) *Pool

+ func New(job Job, middlewares ...JobMiddleware) (*Pool, error)

+ func NewWithConfig(job Job, cfg Config, middlewares ...JobMiddleware) (*Pool, error)

+ func (p *Pool) Close(ctx context.Context) error

+ func (p *Pool) CloseWIthTimeout(timeout time.Duration) error

+ func (p *Pool) Current() int

+ func (p *Pool) Less() error

+ func (p *Pool) More() error

+ func (p *Pool) Start() error

+ func (p *Pool) StopOne(ctx context.Context) error