middleware

Documentation

Index

• Variables
• func WhiteIpMiddleware(whiteList map[string][]string) server.Option
• type MetaTTHeaderHandler
  • func (ch *MetaTTHeaderHandler) ReadMeta(ctx context.Context, msg remote.Message) (context.Context, error)
  • func (ch *MetaTTHeaderHandler) WriteMeta(ctx context.Context, msg remote.Message) (context.Context, error)

Variables

var ClientMetaHandler = client.WithMetaHandler(&MetaTTHeaderHandler{})

var ErrHandlerOption = client.WithErrorHandler(func(ctx context.Context, err error) error {
	transErr, ok := err.(*remote.TransError)
	if ok && transErr.TypeID() == 6 {
		err = e.RPCClientErrorCodeError.SetErr(err, strings.ReplaceAll(transErr.Error(), "biz error: ", ""))
	} else {
		err = e.RPCClientErrorCodeError.SetErr(err, "数据访问失败")
	}
	return err
})

ErrHandlerOption 业务错误再封装

var ServerMetaHandler = server.WithMetaHandler(&MetaTTHeaderHandler{})

Functions

func WhiteIpMiddleware

func WhiteIpMiddleware(whiteList map[string][]string) server.Option

Types

type MetaTTHeaderHandler

type MetaTTHeaderHandler struct {
	WhiteApi   []string //接口白名单
	CheckWhite bool
}

func (*MetaTTHeaderHandler) ReadMeta

func (ch *MetaTTHeaderHandler) ReadMeta(ctx context.Context, msg remote.Message) (context.Context, error)

ReadMeta of MetaTTHeaderHandler reads headers of TTHeader protocol from transport

func (*MetaTTHeaderHandler) WriteMeta

func (ch *MetaTTHeaderHandler) WriteMeta(ctx context.Context, msg remote.Message) (context.Context, error)