Method getFunctionByFunctionBrn

pkg/controller/invoke.go:207–243

(ctx *InvokeContext, input *api.GetFunctionInput)

}

func (controller *Controller) getFunctionByFunctionBrn(ctx *InvokeContext, input *api.GetFunctionInput) (hitCache bool, err error) {
	hitCache = false
	if ctx.Brn, err = parseBrn(ctx); err != nil {
		return
	}
	// get latest version function without cache
	ctx.Logger.V(6).Infof("brn version %+v", ctx.Qualifier)

	if !api.RegVersion.MatchString(ctx.Qualifier) {
		if !controller.runOptions.EnableCanary {
			err = innerErr.NewInvalidParameterValueException("invalid brn", nil)
			return false, err
		}
		if err := controller.getCanaryFunctionBrn(ctx); err != nil {
			return false, err
		}
	}

	if ctx.Qualifier == "$LATEST" {
		input.WithCache = false
	}
	brnStr := ctx.Brn.String()
	input.SetFunctionName(brnStr).SetQualifier(ctx.Qualifier)
	ctx.Logger.Debugf("function_input=%v", input)

	defer ctx.Logger.TimeTrack(time.Now(), "GetFunction",
		zap.String("function_name", *input.FunctionName),
		zap.String("qualifier", *input.Qualifier),
	)

	if ctx.Function, hitCache, err = ctx.Clients.DataStorer.GetFunction(input); err != nil {
		ctx.Logger.Debugf("function store get failed, err(%+v)", err)
		return hitCache, err
	}

	return hitCache, nil
}

func (controller *Controller) getCanaryFunctionBrn(ctx *InvokeContext) (err error) {
	input := &api.GetAliasInput{