thread

Dec 16, 2024

Changes in this version

+ const DefaultThreadErrorMaxRetries

+ const DefaultThreadErrorRereyDelay

+ func Retry(config *RetryConfig, shouldRetry ShouldRetry, fn func() error) (err error)

+ type Group struct

+ ResultC chan Result

+ func NewGroup() *Group

+ func (g *Group) Go(job interface{}, fn func(job interface{}) error)

+ func (g *Group) SetLimit(n int)

+ func (g *Group) Wait()

+ type Result struct

+ Duration string

+ Error error

+ Task interface{}

+ type RetryConfig struct

+ Delay time.Duration

+ MaxRetries int

+ type ShouldRetry func(error) bool