state

Documentation

Index

• type BatchError
  • func (be *BatchError) Add(err error)
  • func (be *BatchError) Err() error
  • func (be *BatchError) Unwrap() []error
• type Handle
  • func NewMerged(parents ...Handle) Handle
  • func NewStream() Handle

Types

type BatchError

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

BatchError collects multiple errors from concurrent workers and can expose them either as one joined error or as a cloned slice.

func (*BatchError) Add

func (be *BatchError) Add(err error)

Add records a non-nil error for later aggregation.

func (*BatchError) Err

func (be *BatchError) Err() error

Err joins all recorded errors. It returns nil when no error was added.

func (*BatchError) Unwrap

func (be *BatchError) Unwrap() []error

Unwrap returns a snapshot of the recorded errors in insertion order.

type Handle

type Handle interface {
	Add(err error, panicOnTerminal bool)
	Err() error
	ShouldPanic() bool
}

Handle abstracts local and merged stream error state.

func NewMerged

func NewMerged(parents ...Handle) Handle

NewMerged creates a state that adds local errors on top of the current error state from parents.

func NewStream

func NewStream() Handle

NewStream returns an empty local stream error state.