validator

Documentation

Index

• Variables
• func NewHook(opts ...Option) *hook
• type ClientErrorFunc
• type Option
  • func ClientReqErrorFn(fn ClientErrorFunc) Option
  • func ClientValidateResponse(b bool) Option
  • func PublishErrorFn(fn PublishErrorFunc) Option
  • func ServerErrorFn(fn ServerErrorFunc) Option
  • func ServerValidateResponse(b bool) Option
  • func SubscribeErrorFn(fn SubscribeErrorFunc) Option
• type Options
  • func NewOptions(opts ...Option) Options
• type PublishErrorFunc
• type ServerErrorFunc
• type SubscribeErrorFunc

Variables

var (
	DefaultClientErrorFunc = func(req client.Request, rsp interface{}, err error) error {
		if rsp != nil {
			return errors.BadGateway(req.Service(), "%v", err)
		}
		return errors.BadRequest(req.Service(), "%v", err)
	}

	DefaultServerErrorFunc = func(req server.Request, rsp interface{}, err error) error {
		if rsp != nil {
			return errors.BadGateway(req.Service(), "%v", err)
		}
		return errors.BadRequest(req.Service(), "%v", err)
	}

	DefaultPublishErrorFunc = func(msg client.Message, err error) error {
		return errors.BadRequest(msg.Topic(), "%v", err)
	}

	DefaultSubscribeErrorFunc = func(msg server.Message, err error) error {
		return errors.BadRequest(msg.Topic(), "%v", err)
	}
)

Functions

func NewHook

func NewHook(opts ...Option) *hook

Types

type ClientErrorFunc

type ClientErrorFunc func(client.Request, interface{}, error) error

type Option

type Option func(*Options)

Option func signature

func ClientReqErrorFn

func ClientReqErrorFn(fn ClientErrorFunc) Option

func ClientValidateResponse

func ClientValidateResponse(b bool) Option

func PublishErrorFn

func PublishErrorFn(fn PublishErrorFunc) Option

func ServerErrorFn

func ServerErrorFn(fn ServerErrorFunc) Option

func ServerValidateResponse

func ServerValidateResponse(b bool) Option

func SubscribeErrorFn

func SubscribeErrorFn(fn SubscribeErrorFunc) Option

type Options

type Options struct {
	ClientErrorFn          ClientErrorFunc
	ServerErrorFn          ServerErrorFunc
	PublishErrorFn         PublishErrorFunc
	SubscribeErrorFn       SubscribeErrorFunc
	ClientValidateResponse bool
	ServerValidateResponse bool
}

Options struct holds wrapper options

func NewOptions

func NewOptions(opts ...Option) Options

type PublishErrorFunc

type PublishErrorFunc func(client.Message, error) error

type ServerErrorFunc

type ServerErrorFunc func(server.Request, interface{}, error) error

type SubscribeErrorFunc

type SubscribeErrorFunc func(server.Message, error) error