task

Documentation

Index

• func Any(ctx context.Context, tasks ...func(ctx context.Context) error) error
• func Run(ctx context.Context, tasks ...func() error) error
• type Group
  • func (g *Group) Append(name string, f func(ctx context.Context) error)
  • func (g *Group) Append0(f func(ctx context.Context) error)
  • func (g *Group) Cleanup(f func())
  • func (g *Group) Concurrency(n int)
  • func (g *Group) FastFail()
  • func (g *Group) Run(contextList ...context.Context) error
  • func (g *Group) RunContextList(contextList []context.Context) error

Functions

func Any

func Any(ctx context.Context, tasks ...func(ctx context.Context) error) error

func Run

func Run(ctx context.Context, tasks ...func() error) error

Types

type Group

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

func (*Group) Append

func (g *Group) Append(name string, f func(ctx context.Context) error)

func (*Group) Append0

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

func (*Group) Cleanup

func (g *Group) Cleanup(f func())

func (*Group) Concurrency

func (g *Group) Concurrency(n int)

func (*Group) FastFail

func (g *Group) FastFail()

func (*Group) Run

func (g *Group) Run(contextList ...context.Context) error

func (*Group) RunContextList

func (g *Group) RunContextList(contextList []context.Context) error