func()

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
}