taskgroup

package module

v0.0.0-...-4f2ca77 Latest Latest Go to latest Published: Jul 6, 2020 License: MIT Imports: 4 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

context.Context native goroutine manager.

This section is empty.

This section is empty.

This section is empty.

type Group struct {
	// contains filtered or unexported fields
}

func FailFast(ctx context.Context, opts ...Option) (*Group, context.Context, context.CancelFunc)

func New(opts ...Option) *Group

func (g *Group) Add(t Task)

func (g *Group) AddFunc(f func(ctx context.Context) error)

func (g *Group) Process(ctx context.Context) error

type Interceptor func(ctx context.Context, report func(error), t Task, r Runner)

func ChainInterceptor(is ...Interceptor) Interceptor

func WithGoroutine() Interceptor

func WithRecover() Interceptor

func WithRetry(strategy func(context.Context, int, error) (time.Duration, bool)) Interceptor

type Option interface {
	// contains filtered or unexported methods
}

func WithFoldFunc(f func(acc, err error) error) Option

type PanicError struct {
	Raw interface{}
}

func (pe *PanicError) Error() string

func (pe *PanicError) Unwrap() error

type Runner interface {
	Run(ctx context.Context, report func(error), t Task)
}

var DefaultRunner Runner = defaultRunner

type Task interface {
	Process(ctx context.Context) error
}

type TaskFunc func(ctx context.Context) error

func (f TaskFunc) Process(ctx context.Context) error