middleware

Documentation

Index

• Variables
• func ChainHeader(ctx context.Context, w http.ResponseWriter, r *http.Request) context.Context
• func DisableRecover()
• type LimitHandler
  • func (h *LimitHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type MuxMiddleware
  • func AuthMiddleWare(authFunc interceptor.Authorize) MuxMiddleware
  • func LimitMiddleWare(limiter *limit.Limiter) MuxMiddleware
  • func RecoverMiddleWare(logger grpc_logging.Logger, bodyMarshaler, errorMarshaler runtime.Marshaler, ...) MuxMiddleware
  • func TracerMiddleWare(t opentracing.Tracer) MuxMiddleware
• type ResponseWriterFunc

Variables

var (
	RequestId            = "request_id"
	RequestIDHeader      = "x-request-id"
	DeviceIDHeader       = "x-device-id"
	PathHeader           = "x-request-path"
	MethodHeader         = "x-request-method"
	TraceidHeader        = "x-b3-traceid"
	SpanidHeader         = "x-b3-spanid"
	ParentspanidHeader   = "x-b3-parentspanid"
	SampledHeader        = "x-b3-sampled"
	FlagsHeader          = "x-b3-flags"
	SpanContextHeader    = "x-ot-span-context"
	ResponseStatusHeader = "x-response-status"

	HeaderMap = map[string]string{
		RequestIDHeader:    RequestId,
		DeviceIDHeader:     "device_id",
		TraceidHeader:      "traceid",
		SpanidHeader:       "spanid",
		SpanidHeader:       "spanid",
		ParentspanidHeader: "parentspanid",
		SampledHeader:      "sampled",
		FlagsHeader:        "flags",
		SpanContextHeader:  "span_context",
	}
)

常用的header key

Functions

func ChainHeader

func ChainHeader(ctx context.Context, w http.ResponseWriter, r *http.Request) context.Context

ChainHeader

func DisableRecover

func DisableRecover()

DisableRecover disable panic recover

Types

type LimitHandler

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

LimitHandler the ratelimit Handler

func (*LimitHandler) ServeHTTP

func (h *LimitHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP the http handler

type MuxMiddleware

type MuxMiddleware func(http.Handler) http.HandlerFunc

MuxMiddleware

func AuthMiddleWare

func AuthMiddleWare(authFunc interceptor.Authorize) MuxMiddleware

AuthMiddleWare

func LimitMiddleWare

func LimitMiddleWare(limiter *limit.Limiter) MuxMiddleware

LimitMiddleWare

func RecoverMiddleWare

func RecoverMiddleWare(logger grpc_logging.Logger, bodyMarshaler,
	errorMarshaler runtime.Marshaler, withoutHTTPStatus bool) MuxMiddleware

RecoverMiddleWare revover add logger

func TracerMiddleWare

func TracerMiddleWare(t opentracing.Tracer) MuxMiddleware

TracerMiddleWare

type ResponseWriterFunc

type ResponseWriterFunc func(w http.ResponseWriter, r *http.Request, block bool, limitMessage string)

ResponseWriterFunc the tesponse writer func when rate limit exceeded