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
}