middleware

Documentation

Overview

Package middleware is a generated GoMock package.

Index

• Constants
• Variables
• type BaseMiddleware
  • func (mw *BaseMiddleware) Handle(ctx core.Context) error
  • func (mw *BaseMiddleware) SetNext(next core.Middleware)
• type HttpInfoInjectorMiddleware
  • func NewHttpInfoInjectorMiddleware(opt HttpInfoInjectorOption) *HttpInfoInjectorMiddleware
  • func (mw *HttpInfoInjectorMiddleware) Handle(ctx core.Context) error
• type HttpInfoInjectorOption
• type HttpInputMiddleware
  • func NewHttpInputMiddleWare(opt HttpInputOption) *HttpInputMiddleware
  • func (mw *HttpInputMiddleware) Handle(ctx core.Context) error
• type HttpInputOption
• type HttpRespReshapeMiddleware
  • func NewRespReshapeMiddleware(respNewFunc func() data.HttpResponse) *HttpRespReshapeMiddleware
  • func (mw *HttpRespReshapeMiddleware) Handle(ctx core.Context) error
• type MockTrafficLogger
  • func NewMockTrafficLogger(ctrl *gomock.Controller) *MockTrafficLogger
  • func (m *MockTrafficLogger) EXPECT() *MockTrafficLoggerMockRecorder
  • func (m *MockTrafficLogger) LogRequest(tr *RequestTrafficLog)
  • func (m *MockTrafficLogger) LogResponse(tr *ResponseTrafficLog)
• type MockTrafficLoggerMockRecorder
  • func (mr *MockTrafficLoggerMockRecorder) LogRequest(tr interface{}) *gomock.Call
  • func (mr *MockTrafficLoggerMockRecorder) LogResponse(tr interface{}) *gomock.Call
• type RequestTrafficLog
• type ResponseTrafficLog
• type TrafficLogMiddleware
  • func NewTrafficLogMiddleware(opt *TrafficLogOpt) *TrafficLogMiddleware
  • func (mw *TrafficLogMiddleware) Handle(ctx core.Context) error
• type TrafficLogOpt
• type TrafficLogger

Constants

const (
	KeyHttpRequest = "HttpRequest"
	KeyRequestID   = "RequestID"
)

Variables

var DefaultValidator = validator.New()

DefaultValidator use a single instance of Validate, it caches struct info

Types

type BaseMiddleware

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

func (*BaseMiddleware) Handle

func (mw *BaseMiddleware) Handle(ctx core.Context) error

func (*BaseMiddleware) SetNext

func (mw *BaseMiddleware) SetNext(next core.Middleware)

type HttpInfoInjectorMiddleware

type HttpInfoInjectorMiddleware struct {
	BaseMiddleware
	// contains filtered or unexported fields
}

func NewHttpInfoInjectorMiddleware

func NewHttpInfoInjectorMiddleware(opt HttpInfoInjectorOption) *HttpInfoInjectorMiddleware

func (*HttpInfoInjectorMiddleware) Handle

func (mw *HttpInfoInjectorMiddleware) Handle(ctx core.Context) error

type HttpInfoInjectorOption

type HttpInfoInjectorOption struct {
	ReqFunc            func() *http.Request
	HeaderKeyRequestID string
}

type HttpInputMiddleware

type HttpInputMiddleware struct {
	BaseMiddleware
	// contains filtered or unexported fields
}

func NewHttpInputMiddleWare

func NewHttpInputMiddleWare(opt HttpInputOption) *HttpInputMiddleware

func (*HttpInputMiddleware) Handle

func (mw *HttpInputMiddleware) Handle(ctx core.Context) error

type HttpInputOption

type HttpInputOption struct {
	PathParamsFunc       func(key string) string
	InputType            reflect.Type
	IsReadFromBody       bool
	DisableUnmarshalBody bool
	Codecs               []codec.Interface
}

type HttpRespReshapeMiddleware

type HttpRespReshapeMiddleware struct {
	BaseMiddleware
	// contains filtered or unexported fields
}

func NewRespReshapeMiddleware

func NewRespReshapeMiddleware(respNewFunc func() data.HttpResponse) *HttpRespReshapeMiddleware

func (*HttpRespReshapeMiddleware) Handle

func (mw *HttpRespReshapeMiddleware) Handle(ctx core.Context) error

type MockTrafficLogger

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

MockTrafficLogger is a mock of TrafficLogger interface.

func NewMockTrafficLogger

func NewMockTrafficLogger(ctrl *gomock.Controller) *MockTrafficLogger

NewMockTrafficLogger creates a new mock instance.

func (*MockTrafficLogger) EXPECT

func (m *MockTrafficLogger) EXPECT() *MockTrafficLoggerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTrafficLogger) LogRequest

func (m *MockTrafficLogger) LogRequest(tr *RequestTrafficLog)

LogRequest mocks base method.

func (*MockTrafficLogger) LogResponse

func (m *MockTrafficLogger) LogResponse(tr *ResponseTrafficLog)

LogResponse mocks base method.

type MockTrafficLoggerMockRecorder

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

MockTrafficLoggerMockRecorder is the mock recorder for MockTrafficLogger.

func (*MockTrafficLoggerMockRecorder) LogRequest

func (mr *MockTrafficLoggerMockRecorder) LogRequest(tr interface{}) *gomock.Call

LogRequest indicates an expected call of LogRequest.

func (*MockTrafficLoggerMockRecorder) LogResponse

func (mr *MockTrafficLoggerMockRecorder) LogResponse(tr interface{}) *gomock.Call

LogResponse indicates an expected call of LogResponse.

type RequestTrafficLog

type RequestTrafficLog struct {
	Context context.Context `json:"-"`

	RequestID string      `json:"request_id,omitempty"`
	Path      string      `json:"path,omitempty"`
	Method    string      `json:"method,omitempty"`
	Input     interface{} `json:"request,omitempty"`
}

type ResponseTrafficLog

type ResponseTrafficLog struct {
	Context context.Context `json:"-"`

	RequestID   string      `json:"request_id,omitempty"`
	Path        string      `json:"path,omitempty"`
	Method      string      `json:"method,omitempty"`
	ElapsedTime int64       `json:"elapsed_time,omitempty"`
	Output      interface{} `json:"response,omitempty"`
	Error       error       `json:"error,omitempty"`
}

type TrafficLogMiddleware

type TrafficLogMiddleware struct {
	BaseMiddleware
	// contains filtered or unexported fields
}

func NewTrafficLogMiddleware

func NewTrafficLogMiddleware(opt *TrafficLogOpt) *TrafficLogMiddleware

func (*TrafficLogMiddleware) Handle

func (mw *TrafficLogMiddleware) Handle(ctx core.Context) error

type TrafficLogOpt

type TrafficLogOpt struct {
	LogReq  bool
	LogResp bool
	Logger  TrafficLogger
}

type TrafficLogger

type TrafficLogger interface {
	LogRequest(tr *RequestTrafficLog)
	LogResponse(tr *ResponseTrafficLog)
}