async

Aug 19, 2024

Changes in this version

type ExecutionErrors

+ func (ee ExecutionErrors) Unwrap() []error

Jul 23, 2024

Changes in this version

+ func SeqGroups(groups ...[]AsyncFn) error

+ func SeqGroupsWithContext(ctx context.Context, groups ...[]AsyncFn) error

Jun 20, 2024

Changes in this version

+ var ErrInvalidSeqFuncs error = errors.New("invalid seq functions")

+ func Seq(funcs ...AsyncFn) ([]any, error)

+ func SeqWithContext(ctx context.Context, funcs ...AsyncFn) ([]any, error)

+ func Series(funcs ...AsyncFn) ([][]any, error)

+ func SeriesWithContext(ctx context.Context, funcs ...AsyncFn) ([][]any, error)

+ func Times(n int, fn AsyncFn) ([][]any, error)

+ func TimesLimit(n, concurrency int, fn AsyncFn) ([][]any, error)

+ func TimesLimitWithContext(ctx context.Context, n, concurrency int, fn AsyncFn) ([][]any, error)

+ func TimesSeries(n int, fn AsyncFn) ([][]any, error)

+ func TimesSeriesWithContext(ctx context.Context, n int, fn AsyncFn) ([][]any, error)

+ func TimesWithContext(ctx context.Context, n int, fn AsyncFn) ([][]any, error)

+ type Paralleler struct

+ func (p *Paralleler) Add(funcs ...AsyncFn) *Paralleler

+ func (p *Paralleler) Clear() *Paralleler

+ func (p *Paralleler) Run() ([][]any, error)

+ func (p *Paralleler) RunCompleted() ([][]any, error)

+ func (p *Paralleler) WithConcurrency(concurrency int) *Paralleler

+ func (p *Paralleler) WithContext(ctx context.Context) *Paralleler

Apr 13, 2024

Changes in this version

+ var ErrInvalidTestFunc error = errors.New("invalid test function")

+ var ErrUnmatchedParam error = errors.New("parameters are unmatched")

+ func Retry(fn AsyncFn, opts ...RetryOptions) ([]any, error)

+ func RetryWithContext(ctx context.Context, fn AsyncFn, opts ...RetryOptions) ([]any, error)

+ func Until(testFn, fn AsyncFn) ([]any, error)

+ func UntilWithContext(ctx context.Context, testFn, fn AsyncFn) ([]any, error)

+ func While(testFn, fn AsyncFn) ([]any, error)

+ func WhileWithContext(ctx context.Context, testFn, fn AsyncFn) ([]any, error)

+ type RetryOptions struct

+ ErrorFilter func(error) bool

+ Interval int

+ IntervalFunc func(int) int

+ Times int

Feb 2, 2024

Changes in this version

+ var ErrNotFunction error = errors.New("not function")

+ func Forever(fn ForeverFn) error

+ func ForeverWithContext(ctx context.Context, fn ForeverFn) error

+ type ExecutionError interface

+ Err func() error

+ Error func() string

+ Index func() int

+ type ExecutionErrors []ExecutionError

+ func (ee ExecutionErrors) Error() string

+ type ForeverFn func(ctx context.Context, next func(context.Context)) error

Jan 7, 2024

Changes in this version

+ var ErrContextCanceled error = errors.New("context canceled")

+ var ErrInvalidConcurrency error = errors.New("invalid concurrency")

+ func Parallel(concurrency int, funcs ...AsyncFn) (int, error)

+ func ParallelCompleted(concurrency int, funcs ...AsyncFn) ([]error, bool)

+ func ParallelCompletedWithContext(ctx context.Context, concurrency int, funcs ...AsyncFn) ([]error, bool)

+ func ParallelWithContext(ctx context.Context, concurrency int, funcs ...AsyncFn) (int, error)

+ type AsyncFn func(context.Context) error

Dec 7, 2023

Changes in this version

+ func All(funcs ...func(context.Context) error) (int, error)

+ func AllCompleted(funcs ...func(context.Context) error) ([]error, bool)

+ func AllCompletedWithContext(ctx context.Context, funcs ...func(context.Context) error) ([]error, bool)

+ func AllWithContext(ctx context.Context, funcs ...func(context.Context) error) (int, error)

+ func Race(funcs ...func(context.Context) error) (int, error)

+ func RaceWithContext(ctx context.Context, funcs ...func(context.Context) error) (int, error)