errctx

Documentation

Index

• type ErrCenter
  • func NewErrCenter() *ErrCenter
  • func (c *ErrCenter) CheckError() error
  • func (c *ErrCenter) OnError(err error)
  • func (c *ErrCenter) WithCancelOnFirstError(ctx context.Context) (context.Context, context.CancelFunc)

Types

type ErrCenter

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

ErrCenter is used to receive errors and provide ways to detect the error(s).

func NewErrCenter

func NewErrCenter() *ErrCenter

NewErrCenter creates a new ErrCenter.

func (*ErrCenter) CheckError

func (c *ErrCenter) CheckError() error

CheckError retusn the recorded error

func (*ErrCenter) OnError

func (c *ErrCenter) OnError(err error)

OnError receivers an error, if the error center has received one, drops the new error and records a warning log. Otherwise the error will be recorded and doneCh will be closed to use as notification.

func (*ErrCenter) WithCancelOnFirstError

func (c *ErrCenter) WithCancelOnFirstError(ctx context.Context) (context.Context, context.CancelFunc)

WithCancelOnFirstError creates an error context which will cancel the context when the first error is received.