in cli_tools/gce_ovf_import/multi_disk_importer/request_builder.go [34:73]
func (r *requestBuilder) buildRequests(params *ovfdomain.OVFImportParams, dataDiskURIs []string) (requests []importer.ImageImportRequest, err error) {
for i, dataDiskURI := range dataDiskURIs {
var source importer.Source
if source, err = r.sourceFactory.Init(dataDiskURI, ""); err != nil {
return nil, err
}
imageNamePrefix := getDisksPrefixName(params)
imageName := daisyutils.GenerateValidDisksImagesName(fmt.Sprintf("%s-%d", imageNamePrefix, i+1))
request := importer.ImageImportRequest{
ExecutionID: imageName,
ImageName: imageName,
CloudLogsDisabled: params.CloudLogsDisabled,
EndpointsOverride: daisyutils.EndpointsOverride{Compute: params.EndpointsOverride.Compute, Storage: params.EndpointsOverride.Storage, CloudLogging: params.EndpointsOverride.CloudLogging},
ComputeServiceAccount: params.ComputeServiceAccount,
WorkflowDir: r.workflowDir,
DaisyLogLinePrefix: fmt.Sprintf("disk-%d", i+1),
GcsLogsDisabled: params.GcsLogsDisabled,
Network: params.Network,
NoExternalIP: params.NoExternalIP,
Oauth: params.Oauth,
Project: *params.Project,
ScratchBucketGcsPath: path.JoinURL(params.ScratchBucketGcsPath, fmt.Sprintf("disk-%s", imageName)),
Source: source,
StdoutLogsDisabled: params.StdoutLogsDisabled,
Subnet: params.Subnet,
NoGuestEnvironment: params.NoGuestEnvironment,
Timeout: params.Deadline.Sub(time.Now()),
Tool: params.GetTool(),
UefiCompatible: params.UefiCompatible,
Zone: params.Zone,
WorkerMachineSeries: params.WorkerMachineSeries,
NestedVirtualizationEnabled: params.NestedVirtualizationEnabled,
DataDisk: true,
}
requests = append(requests, request)
}
return requests, nil
}