in cmd/resource/resource.go [13:39]
func Create(req handler.Request, _ *Model, model *Model) (handler.ProgressEvent, error) {
defer logPanic()
stage := getStage(req.CallbackContext)
switch stage {
case InitStage:
log.Println("Starting InitStage...")
return createInit(req, model), nil
case LambdaInitStage:
log.Println("Starting InitLambdaStage...")
return initLambda(req, model), nil
case LambdaStablilize:
log.Println("Starting LambdaStablilizeStage...")
return createLambdaStabilize(req, model), nil
case ClusterStablilize:
log.Println("Starting ClusterStablilizeStage...")
return createClusterStabilize(req, model), nil
case IamAuthStage:
log.Println("Starting IamAuthStage...")
return createIamAuthHandler(req, model), nil
case UpdateClusterStage:
log.Println("Starting UpdateClusterStage...")
return createFinalize(req, model), nil
default:
log.Println("Failed to identify stage.")
return errorEvent(model, errors.New(fmt.Sprintf("Unhandled stage %s", stage))), nil
}
}