Method getRuntime

pkg/controller/invoke.go:313–361

(ctx *InvokeContext)

}

func (controller *Controller) getRuntime(ctx *InvokeContext) (err error) {
	runtimeT := api.RuntimeViaUnknown
	if ctx.RunOptions.RecommendedOptions.Features.EnableMetrics {
		ctx.Metrics.StepStart(StageGetPodWarm)
		ctx.Metrics.StepStart(StageGetPodCold)
		defer func() {
			if runtimeT == api.RuntimeViaWarm {
				ctx.Metrics.StepDone(StageGetPodWarm)
				ctx.Metrics.ScrapStage(StageGetPodCold)
			} else if runtimeT == api.RuntimeViaCold {
				ctx.Metrics.StepDone(StageGetPodCold)
				ctx.Metrics.ScrapStage(StageGetPodWarm)
			}

			ctx.Metrics.SetLabel(podSourceLabel, runtimeT)
		}()
	}

	ctx.Input = &rtctrl.InvocationInput{
		ExternalRequestID: ctx.ExternalRequestID,
		RequestID:         ctx.RequestID,
		User:              ctx.OwnerUser,
		Code:              ctx.Function.Code,
		Configuration:     ctx.Function.Configuration,
		LogConfig:         ctx.Function.LogConfig,
		EnableMetrics:     ctx.RunOptions.RecommendedOptions.Features.EnableMetrics,
		IsLogTail:         ctx.LogType.IsLogTypeTail(),
		Request:           ctx.Request,
		Response:          ctx.Response,
		Logger:            ctx.Logger,
		InvokeType:        ctx.InvokeType,
		TriggerType:       ctx.TriggerType,
	}

	if ctx.WithStreamMode || strings.HasSuffix(ctx.Runtime.Name, "stream") {
		ctx.WithStreamMode = true
		ctx.Input.WithStreamMode = true
	}
	for i := 0; i < 2; i++ {
		runtimeT, err = controller.tryGetRuntime(ctx)
		if err != nil {
			ctx.Logger.Errorf("#%d try to get runtime failed: %s", i, err.Error())
		} else {
			break
		}
	}

	return
}

func (controller *Controller) tryGetRuntime(ctx *InvokeContext) (runtimeType string, err error) {
	runtimeType = api.RuntimeViaUnknown