concurrent

Documentation

Index

• func Go(fn func())
• type CtxWaitGroup
  • func NewCtxWaitGroup(ctx context.Context) *CtxWaitGroup
  • func (cwg *CtxWaitGroup) Go(fn func())
  • func (cwg *CtxWaitGroup) Wait() error
• type ErrGroup
  • func NewErrGroup(ctx context.Context) *ErrGroup
  • func (eg *ErrGroup) Go(fn func() error)
  • func (eg *ErrGroup) Wait() error
• type WaitGroup
  • func NewWaitGroup() *WaitGroup
  • func (wg *WaitGroup) Go(fn func())
  • func (wg *WaitGroup) GoC(ctx context.Context, fn func())
  • func (wg *WaitGroup) Wait()

Functions

func Go

func Go(fn func())

Types

type CtxWaitGroup

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

func NewCtxWaitGroup

func NewCtxWaitGroup(ctx context.Context) *CtxWaitGroup

func (*CtxWaitGroup) Go

func (cwg *CtxWaitGroup) Go(fn func())

func (*CtxWaitGroup) Wait

func (cwg *CtxWaitGroup) Wait() error

type ErrGroup

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

func NewErrGroup

func NewErrGroup(ctx context.Context) *ErrGroup

func (*ErrGroup) Go

func (eg *ErrGroup) Go(fn func() error)

func (*ErrGroup) Wait

func (eg *ErrGroup) Wait() error

type WaitGroup

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

func NewWaitGroup

func NewWaitGroup() *WaitGroup

func (*WaitGroup) Go

func (wg *WaitGroup) Go(fn func())

func (*WaitGroup) GoC

func (wg *WaitGroup) GoC(ctx context.Context, fn func())

func (*WaitGroup) Wait

func (wg *WaitGroup) Wait()