debug

Jan 1, 2024

Changes in this version

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

+ func PanicDecoderWrapper(wrapped utils.DecoderFunc) utils.DecoderFunc

+ func WrapPanicProducer(wrapped producer.ProducerInterface) producer.ProducerInterface

+ type PanicErrorMessage struct

+ Inner string

+ Msg interface{}

+ Stacktrace []byte

+ func (e *PanicErrorMessage) Error() string

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

+ type PanicProducerWrapper struct

+ 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)