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