multierr

Documentation

Index

• type ErrGroup
  • func NewErrGroup(ctx context.Context) (*ErrGroup, context.Context)
  • func (g *ErrGroup) Go(f func() error)
  • func (g *ErrGroup) Wait() *Errors
• type Errors
  • func (e *Errors) Collect(err error) *Errors
  • func (e *Errors) Error() string
  • func (e *Errors) HasErrors() bool
  • func (e *Errors) Merge(o *Errors) *Errors
  • func (e *Errors) NilOrError() error

Types

type ErrGroup

type ErrGroup struct {
	*errgroup.Group
	// contains filtered or unexported fields
}

func NewErrGroup

func NewErrGroup(ctx context.Context) (*ErrGroup, context.Context)

func (*ErrGroup) Go

func (g *ErrGroup) Go(f func() error)

func (*ErrGroup) Wait

func (g *ErrGroup) Wait() *Errors

type Errors

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

Errors represent a list of errors triggered during the execution of a goka view/processor. Normally, the first error leads to stopping the processor/view, but during shutdown, more errors might occur.

func (*Errors) Collect

func (e *Errors) Collect(err error) *Errors

func (*Errors) Error

func (e *Errors) Error() string

func (*Errors) HasErrors

func (e *Errors) HasErrors() bool

func (*Errors) Merge

func (e *Errors) Merge(o *Errors) *Errors

func (*Errors) NilOrError

func (e *Errors) NilOrError() error