func Create()

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
	}
}