recoverer

Documentation

Index

• type Recoverer
  • func New(t transport.Transport, l log.Logger) *Recoverer
  • func (r *Recoverer) Broadcast(topic string, message transport.Message) (err error)
  • func (r *Recoverer) Messages(topic string) <-chan transport.ReceivedMessage
  • func (r *Recoverer) Start(ctx context.Context) error
  • func (r *Recoverer) Wait() <-chan error

Types

type Recoverer

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

Recoverer is a transport wrapper that handles panics that occur in the underlying transport.

func New

func New(t transport.Transport, l log.Logger) *Recoverer

New creates a new Recoverer transport.

func (*Recoverer) Broadcast

func (r *Recoverer) Broadcast(topic string, message transport.Message) (err error)

Broadcast implements the transport.Transport interface.

func (*Recoverer) Messages

func (r *Recoverer) Messages(topic string) <-chan transport.ReceivedMessage

Messages implements the transport.Transport interface.

func (*Recoverer) Start

func (r *Recoverer) Start(ctx context.Context) error

Start implements the transport.Transport interface.

func (*Recoverer) Wait

func (r *Recoverer) Wait() <-chan error

Wait implements the transport.Transport interface.