debug

package

v2.2.6 Latest Latest Go to latest Published: Dec 27, 2025 License: BSD-3-Clause Imports: 4 Imported by: 2

Details

Package debug provides panic-wrapping helpers for decoders and producers.

This section is empty.

View Source

var (
	// ErrPanic marks a recovered panic.
	ErrPanic = fmt.Errorf("panic")
)

func PanicDecoderWrapper(wrapped utils.DecoderFunc) utils.DecoderFunc

PanicDecoderWrapper wraps a decoder to recover panics as errors.

func WrapPanicProducer(wrapped producer.ProducerInterface) producer.ProducerInterface

WrapPanicProducer wraps a producer to recover panics as errors.

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

PanicErrorMessage captures a recovered panic with stacktrace.

func (e *PanicErrorMessage) Error() string

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

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

PanicProducerWrapper wraps a producer to recover panics during Produce.

func (p *PanicProducerWrapper) Close()

Close forwards Close to the wrapped producer.

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

Commit forwards Commit to the wrapped producer.

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

Produce calls the wrapped producer and converts panics into errors.