Method ServeHTTP

proxy/proxy.go:1754–1903

ServeHTTP is the proxy http.Handler implementation

(w http.ResponseWriter, r *http.Request)

// ServeHTTP is the proxy http.Handler implementation
func (p *Proxy) ServeHTTP(w http.ResponseWriter, r *http.Request) {

	var requestElapsed, responseElapsed time.Duration
	requestStopWatch, responseStopWatch := newStopWatch(), newStopWatch()
	requestStopWatch.Start()

	lw := logging.NewLoggingWriter(w)

	p.metrics.IncCounter("incoming." + r.Proto)
	var ctx *context

	spanOpts := []ot.StartSpanOption{ot.Tags{
		SpanKindTag: SpanKindServer,
	}}
	if wireContext, err := p.tracing.tracer.Extract(ot.HTTPHeaders, ot.HTTPHeadersCarrier(r.Header)); err == nil {
		spanOpts = append(spanOpts, ext.RPCServerOption(wireContext))
	}
	span := p.tracing.tracer.StartSpan(p.tracing.initialOperationName, spanOpts...)

	defer func() {
		if ctx != nil && ctx.proxySpan != nil {
			ctx.proxySpan.Finish()
		}
		span.Finish()
		requestStopWatch.Stop()
		responseStopWatch.Stop()

		p.metrics.MeasureProxy(requestElapsed+requestStopWatch.Elapsed(), responseElapsed+responseStopWatch.Elapsed())
	}()

	defer func() {
		accessLogEnabled, ok := ctx.stateBag[al.AccessLogEnabledKey].(*al.AccessLogFilter)
		if !ok {
			if p.accessLogDisabled {
				accessLogEnabled = &disabledAccessLog
			} else {
				accessLogEnabled = &enabledAccessLog
			}
		}

		statusCode := lw.GetCode()

		if shouldLog(statusCode, accessLogEnabled) {
			authUser, _ := ctx.stateBag[filterslog.AuthUserKey].(string)
			entry := &logging.AccessEntry{
				Request:      r,
				ResponseSize: lw.GetBytes(),
				StatusCode:   statusCode,
				RequestTime:  ctx.startServe,
				Duration:     time.Since(ctx.startServe),
				AuthUser:     authUser,
			}

			additionalData, _ := ctx.stateBag[al.AccessLogAdditionalDataKey].(map[string]interface{})
			if p.accessLogger != nil {
				p.accessLogger.LogAccess(entry, additionalData)
			}
		}