Versions in this module Expand all Collapse all v0 v0.0.1 Jan 1, 2023 Changes in this version + func NewScaler(pool *Pool) + type Context struct + func NewContext() *Context + func (ctx *Context) Close() error + func (ctx *Context) Deadline() (deadline time.Time, ok bool) + func (ctx *Context) Done() <-chan struct{} + func (ctx *Context) Err() error + func (ctx *Context) Error() string + func (ctx *Context) Read(p []byte) (n int, err error) + func (ctx *Context) Root() context.Context + func (ctx *Context) Value(key any, val any) any + func (ctx *Context) WG(idx int, val int) *sync.WaitGroup + func (ctx *Context) Wait(idx int) (err error) + func (ctx *Context) Write(p []byte) (n int, err error) + type Fibonacci struct + func (strategy *Fibonacci) Do(fn Job) error + type Job interface + Do func() error + func NewJob(jobType Job) Job + func NewRetriableJob(ctx Context, fn Job, tries int) Job + type Pool struct + func NewPool(ctx *Context) *Pool + func (pool *Pool) Do(jobType Job) + func (pool *Pool) Run() *Pool + type RetriableJob struct + func (job RetriableJob) Do() error + type Retrier interface + Do func(Job) error + func NewFibonacci(max int) Retrier + func NewRetrier(retrierType Retrier) Retrier + type Scaler struct + type Worker struct + func NewWorker(pool *Pool) *Worker + func (worker *Worker) Close() error + func (worker *Worker) Read(p []byte) (n int, err error) + func (worker *Worker) Write(p []byte) (n int, err error)
Go to main page