Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ErrGroup ¶
ErrGroup implements a group of parallel running tasks allowing to wait for all routines to terminate, as well as error handling.
func NewErrGroup ¶
NewErrGroup creates a new ErrGroup using passed context.
func (*ErrGroup) Go ¶
Go starts a new goroutine. Termination of all functions can be checked via Wait or WaitChan. The ErrGroup closes the internal context when the first go-routine returns with an error.
func (*ErrGroup) Wait ¶
func (g *ErrGroup) Wait() *multierror.Error
Wait blocks until all goroutines of the error group have terminated and returns the accumulated errors.
func (*ErrGroup) WaitChan ¶ added in v1.1.0
func (g *ErrGroup) WaitChan() <-chan *multierror.Error
WaitChan returns a channel that is closed after the error group terminates, possibly containing the error
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. DEPRECATED. This will be removed one day, we migrated to the implementation in github.com/hashicorp/go-multierror
Source Files