Method buildResponse

pkg/controller/invoke.go:411–461

(ctx *InvokeContext, output *rtctrl.InvocationResponse)

}

func (controller *Controller) buildResponse(ctx *InvokeContext, output *rtctrl.InvocationResponse) {
	status := http.StatusOK
	if ctx.RunOptions.RecommendedOptions.Features.EnableMetrics {
		defer func() {
			ctx.Logger.V(9).Infof("user function response code %d", status)
			ctx.Metrics.SetLabel(responseCodeLabel, strconv.Itoa(status))
		}()
	}

	if ctx.Output == nil {
		status = http.StatusBadRequest
		ctx.Response.SetStatusCode(http.StatusBadRequest)
		ctx.Response.SetBody([]byte(NoOutputMsg))
		return
	}

	//ctx.Logger.V(6).Info("invoke output",
	//	zap.String("func_result", "(skipped)"),
	//	zap.Int("func_result_len", len(output.FuncResult)),
	//	zap.String("log_message", "(skipped)"),
	//	zap.Int("log_message_len", len(output.LogMessage)),
	//	zap.String("func_error", output.FuncError),
	//	zap.String("error_info", output.ErrorInfo))

	funcError := output.FuncError
	payload := getFuncResult(output)
	var logMessage []string
	if ctx.LogType.IsLogTypeTail() {
		logMessage = output.LogMessage
	}

	ctx.Response.SetStatusCode(http.StatusOK)

	if ctx.Statistic.Statistic != nil {
		ctx.Response.SetHeader(api.HeadereasyfaasExecTime, strconv.FormatFloat(ctx.Statistic.Statistic.Duration, 'f', 3, 64))
	}

	if ctx.Input.EnableMetrics {
		ctx.Metrics.rtCtrl = ctx.Statistic.Metric
	}

	if ctx.WithStreamMode || ctx.InvokeType == api.InvokeTypeEvent {
		return
	}
	if ctx.LogToBody {
		status = buildTotallyToBody(ctx, funcError, payload, logMessage)
	} else {
		status = build(ctx, funcError, payload, logMessage)
	}
	return
}

func buildTotallyToBody(ctx *InvokeContext, funcError, payload string, logMessage []string) (status int) {
	status = http.StatusOK