client

Documentation

Index

• func DecodeErrorWithDecoder(header nats.Header, payload []byte, errorDecoder ErrorDecoderFn) error
• type ErrorDecoderFn
• type Options

Functions

func DecodeErrorWithDecoder

func DecodeErrorWithDecoder(header nats.Header, payload []byte, errorDecoder ErrorDecoderFn) error

Types

type ErrorDecoderFn

type ErrorDecoderFn func(code string, description string, payload []byte) error

type Options

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