func processInstalling()

in pkg/packages/manager.go [141:175]


func processInstalling(mc *ManagerContext) bool {
	mc.Package.Status.Source = mc.Source
	mc.Log.Info("installing/updating", "chart", mc.Source)
	var err error
	var values map[string]interface{}
	if values, err = mc.Package.GetValues(); err != nil {
		mc.Package.Status.Detail = err.Error()
		mc.Log.Error(err, "Install failed")
		return true
	}
	values[sourceRegistry] = mc.getImageRegistry(values)
	if mc.Source.Registry == "" {
		mc.Source.Registry = mc.PBC.GetDefaultRegistry()
	}
	if err := mc.PackageDriver.Initialize(mc.Ctx, mc.Package.GetClusterName()); err != nil {
		mc.Package.Status.Detail = err.Error()
		return true
	}

	createNamespace := mc.PBC.Spec.CreateNamespace
	if err := mc.PackageDriver.Install(mc.Ctx, mc.Package.Name, mc.Package.Spec.TargetNamespace, createNamespace, mc.Source, values); err != nil {
		mc.Package.Status.Detail = err.Error()
		mc.Log.Error(err, "Install failed")
		return true
	}
	mc.Log.Info("Installed", "name", mc.Package.Name, "chart", mc.Package.Status.Source)
	mc.Package.Status.State = api.StateInstalled
	mc.Package.Status.CurrentVersion = mc.Source.Version
	mc.Package.Status.Detail = ""
	if len(mc.Package.GetClusterName()) == 0 {
		mc.Package.Status.Detail = "Deprecated package namespace. Move to eksa-packages-" + os.Getenv("CLUSTER_NAME")
	}
	mc.Package.Spec.DeepCopyInto(&mc.Package.Status.Spec)
	return true
}