client

Documentation

Index

• func DecodeErrorFromHeaderWithDecoder(header nats.Header, errorDecoder ErrorDecoderFn) error
• type ErrorDecoderFn
• type Options

Functions

func DecodeErrorFromHeaderWithDecoder

func DecodeErrorFromHeaderWithDecoder(header nats.Header, errorDecoder ErrorDecoderFn) error

Types

type ErrorDecoderFn

type ErrorDecoderFn func(code string, description string) error

type Options

type Options struct {
	NatsConnection      *nats.Conn
	Encoder             encoder.Encoder
	IsValidationEnabled bool
	GetSubject          subject.GetSubjectFn
	Timeout             time.Duration
	ErrorDecoder        ErrorDecoderFn
	Tracer              opentracing.Tracer
}