debug

Documentation

Index

• Variables
• func PanicDecoderWrapper(wrapped utils.DecoderFunc) utils.DecoderFunc
• func WrapPanicProducer(wrapped producer.ProducerInterface) producer.ProducerInterface
• type PanicErrorMessage
  • func (e *PanicErrorMessage) Error() string
  • func (e *PanicErrorMessage) Unwrap() []error
• type PanicProducerWrapper
  • func (p *PanicProducerWrapper) Close()
  • func (p *PanicProducerWrapper) Commit(flowMessageSet []producer.ProducerMessage)
  • func (p *PanicProducerWrapper) Produce(msg interface{}, args *producer.ProduceArgs) (flowMessageSet []producer.ProducerMessage, err error)

Variables

var (
	PanicError = fmt.Errorf("panic")
)

Functions

func PanicDecoderWrapper

func PanicDecoderWrapper(wrapped utils.DecoderFunc) utils.DecoderFunc

func WrapPanicProducer

func WrapPanicProducer(wrapped producer.ProducerInterface) producer.ProducerInterface

Types

type PanicErrorMessage

type PanicErrorMessage struct {
	Msg        interface{}
	Inner      string
	Stacktrace []byte
}

func (*PanicErrorMessage) Error

func (e *PanicErrorMessage) Error() string

func (*PanicErrorMessage) Unwrap

func (e *PanicErrorMessage) Unwrap() []error

type PanicProducerWrapper

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

func (*PanicProducerWrapper) Close

func (p *PanicProducerWrapper) Close()

func (*PanicProducerWrapper) Commit

func (p *PanicProducerWrapper) Commit(flowMessageSet []producer.ProducerMessage)

func (*PanicProducerWrapper) Produce

func (p *PanicProducerWrapper) Produce(msg interface{}, args *producer.ProduceArgs) (flowMessageSet []producer.ProducerMessage, err error)