Skip to content

Commit 8e8e4e8

Browse files
committed
refactor openstack plan builder
Signed-off-by: Arik Hadas <ahadas@redhat.com>
1 parent 1a9f7ba commit 8e8e4e8

File tree

1 file changed

+9
-10
lines changed

1 file changed

+9
-10
lines changed

pkg/controller/plan/adapter/openstack/builder.go

Lines changed: 9 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -906,15 +906,15 @@ func (r *Builder) PopulatorVolumes(vmRef ref.Ref, annotations map[string]string,
906906
return
907907
}
908908

909-
func (r *Builder) getCorrespondingPvc(image model.Image, workload *model.Workload, vmRef ref.Ref, annotations map[string]string, secretName string) (*core.PersistentVolumeClaim, error) {
910-
if populatorName, err := r.ensureVolumePopulator(workload, &image, secretName); err == nil {
911-
return r.ensureVolumePopulatorPVC(workload, &image, annotations, populatorName)
912-
} else {
913-
return nil, err
909+
func (r *Builder) getCorrespondingPvc(image model.Image, workload *model.Workload, vmRef ref.Ref, annotations map[string]string, secretName string) (pvc *core.PersistentVolumeClaim, err error) {
910+
populatorCR, err := r.ensureVolumePopulator(workload, &image, secretName)
911+
if err != nil {
912+
return
914913
}
914+
return r.ensureVolumePopulatorPVC(workload, &image, annotations, populatorCR.Name)
915915
}
916916

917-
func (r *Builder) ensureVolumePopulator(workload *model.Workload, image *model.Image, secretName string) (populatorName string, err error) {
917+
func (r *Builder) ensureVolumePopulator(workload *model.Workload, image *model.Image, secretName string) (populatorCR *api.OpenstackVolumePopulator, err error) {
918918
volumePopulatorCR, err := r.getVolumePopulatorCR(image.Name)
919919
if err != nil {
920920
if !k8serr.IsNotFound(err) {
@@ -923,7 +923,7 @@ func (r *Builder) ensureVolumePopulator(workload *model.Workload, image *model.I
923923
}
924924
return r.createVolumePopulatorCR(*image, secretName, workload.ID)
925925
}
926-
populatorName = volumePopulatorCR.Name
926+
populatorCR = &volumePopulatorCR
927927
return
928928
}
929929

@@ -995,8 +995,8 @@ func (r *Builder) getImagesFromVolumes(workload *model.Workload) (images []model
995995
return
996996
}
997997

998-
func (r *Builder) createVolumePopulatorCR(image model.Image, secretName, vmId string) (name string, err error) {
999-
populatorCR := &api.OpenstackVolumePopulator{
998+
func (r *Builder) createVolumePopulatorCR(image model.Image, secretName, vmId string) (populatorCR *api.OpenstackVolumePopulator, err error) {
999+
populatorCR = &api.OpenstackVolumePopulator{
10001000
ObjectMeta: meta.ObjectMeta{
10011001
Name: image.Name,
10021002
Namespace: r.Plan.Spec.TargetNamespace,
@@ -1014,7 +1014,6 @@ func (r *Builder) createVolumePopulatorCR(image model.Image, secretName, vmId st
10141014
err = liberr.Wrap(err)
10151015
return
10161016
}
1017-
name = populatorCR.Name
10181017
return
10191018
}
10201019

0 commit comments

Comments
 (0)