errbus

Documentation

Index

• type Bus
  • func New() *Bus
  • func (b *Bus) Publish(ctx context.Context, err error) error
  • func (b *Bus) Subscribe(ctx context.Context) <-chan error

Types

type Bus

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

Bus is an error bus that can be used to provide an async error API.

func New

func New() *Bus

New returns a new Bus.

func (*Bus) Publish

func (b *Bus) Publish(ctx context.Context, err error) error

Publish publishes the error to all subscribers.

func (*Bus) Subscribe

func (b *Bus) Subscribe(ctx context.Context) <-chan error

Subscribe returns a channel of errors. When an error is published through b.Publish, that error will be received from the error channel.