in testworkflow.go [356:385]
func (t *TestWorkflow) appendCreateMountDisksStep(diskParams *compute.Disk) (*daisy.Step, error) {
if diskParams == nil || diskParams.Name == "" {
return nil, fmt.Errorf("failed to create disk with empty parameters")
}
mountdisk := &daisy.Disk{}
mountdisk.Name = diskParams.Name
mountdisk.Type = diskParams.Type
mountdisk.Zone = diskParams.Zone
if diskParams.SizeGb == 0 {
return nil, fmt.Errorf("failed to create mount disk with no SizeGb parameter")
}
mountdisk.SizeGb = strconv.FormatInt(diskParams.SizeGb, 10)
createDisks := &daisy.CreateDisks{mountdisk}
createDisksStep, ok := t.wf.Steps[createDisksStepName]
if ok {
// append to existing step.
*createDisksStep.CreateDisks = append(*createDisksStep.CreateDisks, mountdisk)
} else {
var err error
createDisksStep, err = t.wf.NewStep(createDisksStepName)
if err != nil {
return nil, err
}
createDisksStep.CreateDisks = createDisks
}
return createDisksStep, nil
}