middleware

Documentation

Index

• Variables
• func LimitConcurrentRequests(maxRequests int) func(http.Handler) http.Handler
• func StatMiddleware(ctx context.Context, router *mux.Router, s stats.Stats, component string) func(http.Handler) http.Handler

Variables

var UncompressMiddleware = func(h http.Handler) http.Handler {
	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		if r.Header.Get("Content-Encoding") == "gzip" {
			r.Body = &gzipReader{body: r.Body}
		}
		h.ServeHTTP(w, r)
	})
}

UncompressMiddleware uncompresses gzipped HTTP requests carrying a 'Content-Encoding: gzip' header.

Functions

func LimitConcurrentRequests

func LimitConcurrentRequests(maxRequests int) func(http.Handler) http.Handler

this is to make sure that we don't have more than `maxClient` in-memory at any point of time. As, having more http client than `maxClient` may lead to gateway OOM kill.

func StatMiddleware

func StatMiddleware(ctx context.Context, router *mux.Router, s stats.Stats, component string) func(http.Handler) http.Handler