func()

in internal/flows/init.go [24:60]


func (i *Initer) Run(ctx context.Context) error {
	i.NodeProvider.PopulateNodeConfigDefaults()

	if err := i.NodeProvider.ValidateConfig(); err != nil {
		return err
	}

	i.Logger.Info("Configuring Aws...")
	if err := i.NodeProvider.ConfigureAws(ctx); err != nil {
		return err
	}

	if err := i.NodeProvider.Enrich(ctx); err != nil {
		return err
	}

	if err := i.NodeProvider.Validate(); err != nil {
		return err
	}

	aspects := i.NodeProvider.GetAspects()
	i.Logger.Info("Setting up system aspects...")
	for _, aspect := range aspects {
		nameField := zap.String("name", aspect.Name())
		i.Logger.Info("Setting up system aspect..", nameField)
		if err := aspect.Setup(); err != nil {
			return err
		}
		i.Logger.Info("Finished setting up system aspect", nameField)
	}

	if err := initDaemons(ctx, i.NodeProvider, i.SkipPhases, i.Logger); err != nil {
		return err
	}

	return i.NodeProvider.Cleanup()
}