Documentation ¶
Index ¶
- Variables
- func CleanDir(dest string) error
- func CopyRegistryImage(url, destDir, pathPrefix, accessKey, secKey, certDir string, ...) error
- func CopyRegistryImageAll(url, destDir, pathPrefix, accessKey, secKey, certDir string, ...) error
- func FindMoRef(uuid string, sdkURL string) (string, error)
- func ParseEndpoint(endpt string) (*url.URL, error)
- func ResizeImage(dataFile, imageSize string, totalTargetSpace int64) error
- func WaitForNbd(pidfile string) error
- type AsyncUploadDataSource
- func (aud *AsyncUploadDataSource) Close() error
- func (aud *AsyncUploadDataSource) GetResumePhase() ProcessingPhase
- func (aud *AsyncUploadDataSource) GetURL() *url.URL
- func (aud *AsyncUploadDataSource) Info() (ProcessingPhase, error)
- func (aud *AsyncUploadDataSource) Process() (ProcessingPhase, error)
- func (aud *AsyncUploadDataSource) Transfer(path string) (ProcessingPhase, error)
- func (aud *AsyncUploadDataSource) TransferFile(fileName string) (ProcessingPhase, error)
- type ConnectionInterface
- type ConnectionWrapper
- type DataProcessor
- type DataSourceInterface
- type DiskService
- type DiskServiceGet
- type DiskServiceGetInterface
- type DiskServiceGetResponseInterface
- type DiskServiceInterface
- type DiskServiceResponse
- type DiskServiceResponseInterface
- type DisksService
- type DisksServiceInterface
- type FormatReaders
- type HTTPDataSource
- func (hs *HTTPDataSource) Close() error
- func (hs *HTTPDataSource) GetURL() *url.URL
- func (hs *HTTPDataSource) Info() (ProcessingPhase, error)
- func (hs *HTTPDataSource) Process() (ProcessingPhase, error)
- func (hs *HTTPDataSource) Transfer(path string) (ProcessingPhase, error)
- func (hs *HTTPDataSource) TransferFile(fileName string) (ProcessingPhase, error)
- type ImageTransferService
- type ImageTransferServiceAddInterface
- type ImageTransferServiceFinalizeRequest
- type ImageTransferServiceFinalizeRequestInterface
- type ImageTransferServiceFinalizeResponse
- type ImageTransferServiceFinalizeResponseInterface
- type ImageTransferServiceInterface
- type ImageTransfersService
- type ImageTransfersServiceAdd
- type ImageTransfersServiceAddResponse
- type ImageTransfersServiceAddResponseInterface
- type ImageTransfersServiceInterface
- type ImageTransfersServiceResponse
- type ImageioDataSource
- func (is *ImageioDataSource) Close() error
- func (is *ImageioDataSource) GetURL() *url.URL
- func (is *ImageioDataSource) Info() (ProcessingPhase, error)
- func (is *ImageioDataSource) Process() (ProcessingPhase, error)
- func (is *ImageioDataSource) Transfer(path string) (ProcessingPhase, error)
- func (is *ImageioDataSource) TransferFile(fileName string) (ProcessingPhase, error)
- type ProcessingPhase
- type RegistryDataSource
- func (rd *RegistryDataSource) Close() error
- func (rd *RegistryDataSource) GetURL() *url.URL
- func (rd *RegistryDataSource) Info() (ProcessingPhase, error)
- func (rd *RegistryDataSource) Process() (ProcessingPhase, error)
- func (rd *RegistryDataSource) Transfer(path string) (ProcessingPhase, error)
- func (rd *RegistryDataSource) TransferFile(fileName string) (ProcessingPhase, error)
- type ResumableDataSource
- type S3Client
- type S3DataSource
- func (sd *S3DataSource) Close() error
- func (sd *S3DataSource) GetURL() *url.URL
- func (sd *S3DataSource) Info() (ProcessingPhase, error)
- func (sd *S3DataSource) Process() (ProcessingPhase, error)
- func (sd *S3DataSource) Transfer(path string) (ProcessingPhase, error)
- func (sd *S3DataSource) TransferFile(fileName string) (ProcessingPhase, error)
- type SystemService
- type SystemServiceInteface
- type UploadDataSource
- func (ud *UploadDataSource) Close() error
- func (ud *UploadDataSource) GetURL() *url.URL
- func (ud *UploadDataSource) Info() (ProcessingPhase, error)
- func (ud *UploadDataSource) Process() (ProcessingPhase, error)
- func (ud *UploadDataSource) Transfer(path string) (ProcessingPhase, error)
- func (ud *UploadDataSource) TransferFile(fileName string) (ProcessingPhase, error)
- type VDDKDataSource
- func (vs *VDDKDataSource) Close() error
- func (vs *VDDKDataSource) GetURL() *url.URL
- func (vs *VDDKDataSource) Info() (ProcessingPhase, error)
- func (vs *VDDKDataSource) Process() (ProcessingPhase, error)
- func (vs *VDDKDataSource) Transfer(path string) (ProcessingPhase, error)
- func (vs *VDDKDataSource) TransferFile(fileName string) (ProcessingPhase, error)
- type ValidationSizeError
Constants ¶
This section is empty.
Variables ¶
var ErrInvalidPath = fmt.Errorf("invalid transfer path")
ErrInvalidPath indicates that the path is invalid.
var ErrRequiresScratchSpace = fmt.Errorf("scratch space required and none found")
ErrRequiresScratchSpace indicates that we require scratch space.
Functions ¶
func CleanDir ¶ added in v1.7.0
CleanDir cleans the contents of a directory including its sub directories, but does NOT remove the directory itself.
func CopyRegistryImage ¶ added in v1.23.6
func CopyRegistryImage(url, destDir, pathPrefix, accessKey, secKey, certDir string, insecureRegistry bool) error
CopyRegistryImage download image from registry with docker image API. It will extract first file under the pathPrefix url: source registry url. destDir: the scratch space destination. pathPrefix: path to extract files from. accessKey: accessKey for the registry described in url. secKey: secretKey for the registry described in url. certDir: directory public CA keys are stored for registry identity verification insecureRegistry: boolean if true will allow insecure registries.
func CopyRegistryImageAll ¶ added in v1.23.6
func CopyRegistryImageAll(url, destDir, pathPrefix, accessKey, secKey, certDir string, insecureRegistry bool) error
CopyRegistryImageAll download image from registry with docker image API. It will extract all files under the pathPrefix url: source registry url. destDir: the scratch space destination. pathPrefix: path to extract files from. accessKey: accessKey for the registry described in url. secKey: secretKey for the registry described in url. certDir: directory public CA keys are stored for registry identity verification insecureRegistry: boolean if true will allow insecure registries.
func FindMoRef ¶ added in v1.23.0
FindMoRef takes the UUID of the VM to migrate and finds its MOref from the given VMware URL.
func ParseEndpoint ¶
ParseEndpoint parses the required endpoint and return the url struct.
func ResizeImage ¶ added in v1.4.0
ResizeImage resizes the images to match the requested size. Sometimes provisioners misbehave and the available space is not the same as the requested space. For those situations we compare the available space to the requested space and use the smallest of the two values.
func WaitForNbd ¶ added in v1.23.0
WaitForNbd waits for nbdkit to start by watching for the existence of the given PID file.
Types ¶
type AsyncUploadDataSource ¶ added in v1.13.0
type AsyncUploadDataSource struct { // Next Phase indicates what the next Processing Phase should be after the transfer completes. ResumePhase ProcessingPhase // contains filtered or unexported fields }
AsyncUploadDataSource is an asynchronouse version of an upload data source, that returns finished phase instead of going to post upload processing phases.
func NewAsyncUploadDataSource ¶ added in v1.13.0
func NewAsyncUploadDataSource(stream io.ReadCloser) *AsyncUploadDataSource
NewAsyncUploadDataSource creates a new instance of an UploadDataSource
func (*AsyncUploadDataSource) Close ¶ added in v1.13.0
func (aud *AsyncUploadDataSource) Close() error
Close closes any readers or other open resources.
func (*AsyncUploadDataSource) GetResumePhase ¶ added in v1.13.0
func (aud *AsyncUploadDataSource) GetResumePhase() ProcessingPhase
GetResumePhase returns the next phase to process when resuming
func (*AsyncUploadDataSource) GetURL ¶ added in v1.13.0
func (aud *AsyncUploadDataSource) GetURL() *url.URL
GetURL returns the url that the data processor can use when converting the data.
func (*AsyncUploadDataSource) Info ¶ added in v1.13.0
func (aud *AsyncUploadDataSource) Info() (ProcessingPhase, error)
Info is called to get initial information about the data.
func (*AsyncUploadDataSource) Process ¶ added in v1.13.0
func (aud *AsyncUploadDataSource) Process() (ProcessingPhase, error)
Process is called to do any special processing before giving the url to the data back to the processor
func (*AsyncUploadDataSource) Transfer ¶ added in v1.13.0
func (aud *AsyncUploadDataSource) Transfer(path string) (ProcessingPhase, error)
Transfer is called to transfer the data from the source to the passed in path.
func (*AsyncUploadDataSource) TransferFile ¶ added in v1.13.0
func (aud *AsyncUploadDataSource) TransferFile(fileName string) (ProcessingPhase, error)
TransferFile is called to transfer the data from the source to the passed in file.
type ConnectionInterface ¶ added in v1.15.0
type ConnectionInterface interface { SystemService() SystemServiceInteface Close() error }
ConnectionInterface defines connection methods
type ConnectionWrapper ¶ added in v1.15.0
type ConnectionWrapper struct {
// contains filtered or unexported fields
}
ConnectionWrapper wraps ovirt connection
func (*ConnectionWrapper) Close ¶ added in v1.15.0
func (wrapper *ConnectionWrapper) Close() error
Close closes the connection to ovirt
func (*ConnectionWrapper) SystemService ¶ added in v1.15.0
func (wrapper *ConnectionWrapper) SystemService() SystemServiceInteface
SystemService returns system service
type DataProcessor ¶ added in v1.8.0
type DataProcessor struct {
// contains filtered or unexported fields
}
DataProcessor holds the fields needed to process data from a data provider.
func NewDataProcessor ¶ added in v1.8.0
func NewDataProcessor(dataSource DataSourceInterface, dataFile, dataDir, scratchDataDir, requestImageSize string) *DataProcessor
NewDataProcessor create a new instance of a data processor using the passed in data provider.
func (*DataProcessor) ProcessData ¶ added in v1.8.0
func (dp *DataProcessor) ProcessData() error
ProcessData is the main synchronous processing loop
func (*DataProcessor) ProcessDataResume ¶ added in v1.13.0
func (dp *DataProcessor) ProcessDataResume() error
ProcessDataResume Resume a paused processor, assumes the provided data source is ResumableDataSource
func (*DataProcessor) ProcessDataWithPause ¶ added in v1.13.0
func (dp *DataProcessor) ProcessDataWithPause() error
ProcessDataWithPause is the main processing loop.
type DataSourceInterface ¶ added in v1.8.0
type DataSourceInterface interface { // Info is called to get initial information about the data. Info() (ProcessingPhase, error) // Transfer is called to transfer the data from the source to the path passed in. Transfer(path string) (ProcessingPhase, error) // TransferFile is called to transfer the data from the source to the file passed in. TransferFile(fileName string) (ProcessingPhase, error) // Process is called to do any special processing before giving the url to the data back to the processor Process() (ProcessingPhase, error) // Geturl returns the url that the data processor can use when converting the data. GetURL() *url.URL // Close closes any readers or other open resources. Close() error }
DataSourceInterface is the interface all data sources should implement.
type DiskService ¶ added in v1.15.0
type DiskService struct {
// contains filtered or unexported fields
}
DiskService wraps ovirt disk service
func (*DiskService) Get ¶ added in v1.15.0
func (service *DiskService) Get() DiskServiceGetInterface
Get returns get service
type DiskServiceGet ¶ added in v1.15.0
type DiskServiceGet struct {
// contains filtered or unexported fields
}
DiskServiceGet wraps ovirt disk get service
func (*DiskServiceGet) Send ¶ added in v1.15.0
func (service *DiskServiceGet) Send() (DiskServiceResponseInterface, error)
Send returns disk get response
type DiskServiceGetInterface ¶ added in v1.15.0
type DiskServiceGetInterface interface {
Send() (DiskServiceResponseInterface, error)
}
DiskServiceGetInterface defines service methods
type DiskServiceGetResponseInterface ¶ added in v1.15.0
DiskServiceGetResponseInterface defines service methods
type DiskServiceInterface ¶ added in v1.15.0
type DiskServiceInterface interface {
Get() DiskServiceGetInterface
}
DiskServiceInterface defines service methods
type DiskServiceResponse ¶ added in v1.15.0
type DiskServiceResponse struct {
// contains filtered or unexported fields
}
DiskServiceResponse wraps ovirt response get service
type DiskServiceResponseInterface ¶ added in v1.15.0
DiskServiceResponseInterface defines service methods
type DisksService ¶ added in v1.15.0
type DisksService struct {
// contains filtered or unexported fields
}
DisksService wraps ovirt disks service
func (*DisksService) DiskService ¶ added in v1.15.0
func (service *DisksService) DiskService(id string) DiskServiceInterface
DiskService returns disk service
type DisksServiceInterface ¶ added in v1.15.0
type DisksServiceInterface interface {
DiskService(string) DiskServiceInterface
}
DisksServiceInterface defines service methods
type FormatReaders ¶ added in v1.8.0
FormatReaders contains the stack of readers needed to get information from the input stream (io.ReadCloser)
func NewFormatReaders ¶ added in v1.8.0
func NewFormatReaders(stream io.ReadCloser, total uint64) (*FormatReaders, error)
NewFormatReaders creates a new instance of FormatReaders using the input stream and content type passed in.
func (*FormatReaders) Close ¶ added in v1.8.0
func (fr *FormatReaders) Close() (rtnerr error)
Close Readers in reverse order.
func (*FormatReaders) StartProgressUpdate ¶ added in v1.10.0
func (fr *FormatReaders) StartProgressUpdate()
StartProgressUpdate starts the go routine to automatically update the progress on a set interval.
func (*FormatReaders) TopReader ¶ added in v1.8.0
func (fr *FormatReaders) TopReader() io.ReadCloser
TopReader return the top-level io.ReadCloser from the receiver Reader "stack".
type HTTPDataSource ¶ added in v1.8.0
type HTTPDataSource struct {
// contains filtered or unexported fields
}
HTTPDataSource is the data provider for http(s) endpoints. Sequence of phases: 1a. Info -> Convert (In Info phase the format readers are configured), if the source Reader image is not archived, and no custom CA is used, and can be converted by QEMU-IMG (RAW/QCOW2) 1b. Info -> TransferArchive if the content type is archive 1c. Info -> Transfer in all other cases. 2a. Transfer -> Process if content type is kube virt 2b. Transfer -> Complete if content type is archive (Transfer is called with the target instead of the scratch space). Non block PVCs only. 3. Process -> Convert
func NewHTTPDataSource ¶ added in v1.8.0
func NewHTTPDataSource(endpoint, accessKey, secKey, certDir string, contentType cdiv1.DataVolumeContentType) (*HTTPDataSource, error)
NewHTTPDataSource creates a new instance of the http data provider.
func (*HTTPDataSource) Close ¶ added in v1.8.0
func (hs *HTTPDataSource) Close() error
Close all readers.
func (*HTTPDataSource) GetURL ¶ added in v1.8.0
func (hs *HTTPDataSource) GetURL() *url.URL
GetURL returns the URI that the data processor can use when converting the data.
func (*HTTPDataSource) Info ¶ added in v1.8.0
func (hs *HTTPDataSource) Info() (ProcessingPhase, error)
Info is called to get initial information about the data.
func (*HTTPDataSource) Process ¶ added in v1.8.0
func (hs *HTTPDataSource) Process() (ProcessingPhase, error)
Process is called to do any special processing before giving the URI to the data back to the processor
func (*HTTPDataSource) Transfer ¶ added in v1.8.0
func (hs *HTTPDataSource) Transfer(path string) (ProcessingPhase, error)
Transfer is called to transfer the data from the source to a scratch location.
func (*HTTPDataSource) TransferFile ¶ added in v1.8.0
func (hs *HTTPDataSource) TransferFile(fileName string) (ProcessingPhase, error)
TransferFile is called to transfer the data from the source to the passed in file.
type ImageTransferService ¶ added in v1.19.0
type ImageTransferService struct {
// contains filtered or unexported fields
}
ImageTransferService wraps ovirt transfer service
func (*ImageTransferService) Finalize ¶ added in v1.19.0
func (service *ImageTransferService) Finalize() ImageTransferServiceFinalizeRequestInterface
Finalize returns image service
type ImageTransferServiceAddInterface ¶ added in v1.15.0
type ImageTransferServiceAddInterface interface { ImageTransfer(imageTransfer *ovirtsdk4.ImageTransfer) *ovirtsdk4.ImageTransfersServiceAddRequest Send() (ImageTransfersServiceAddResponseInterface, error) }
ImageTransferServiceAddInterface defines service methods
type ImageTransferServiceFinalizeRequest ¶ added in v1.19.0
type ImageTransferServiceFinalizeRequest struct {
// contains filtered or unexported fields
}
ImageTransferServiceFinalizeRequest warps finalize request
func (*ImageTransferServiceFinalizeRequest) Send ¶ added in v1.19.0
func (service *ImageTransferServiceFinalizeRequest) Send() (ImageTransferServiceFinalizeResponseInterface, error)
Send returns disk get response
type ImageTransferServiceFinalizeRequestInterface ¶ added in v1.19.0
type ImageTransferServiceFinalizeRequestInterface interface {
Send() (ImageTransferServiceFinalizeResponseInterface, error)
}
ImageTransferServiceFinalizeRequestInterface defines service methods
type ImageTransferServiceFinalizeResponse ¶ added in v1.19.0
type ImageTransferServiceFinalizeResponse struct {
// contains filtered or unexported fields
}
ImageTransferServiceFinalizeResponse warps finalize response
type ImageTransferServiceFinalizeResponseInterface ¶ added in v1.19.0
type ImageTransferServiceFinalizeResponseInterface interface { }
ImageTransferServiceFinalizeResponseInterface defines service methods
type ImageTransferServiceInterface ¶ added in v1.19.0
type ImageTransferServiceInterface interface {
Finalize() ImageTransferServiceFinalizeRequestInterface
}
ImageTransferServiceInterface defines service methods
type ImageTransfersService ¶ added in v1.15.0
type ImageTransfersService struct {
// contains filtered or unexported fields
}
ImageTransfersService wraps ovirt transfer service
func (*ImageTransfersService) Add ¶ added in v1.15.0
func (service *ImageTransfersService) Add() ImageTransferServiceAddInterface
Add returns image transfer add request
func (*ImageTransfersService) ImageTransferService ¶ added in v1.19.0
func (service *ImageTransfersService) ImageTransferService(id string) ImageTransferServiceInterface
ImageTransferService returns image service
type ImageTransfersServiceAdd ¶ added in v1.15.0
type ImageTransfersServiceAdd struct {
// contains filtered or unexported fields
}
ImageTransfersServiceAdd wraps ovirt add transfer service
func (*ImageTransfersServiceAdd) Send ¶ added in v1.15.0
func (service *ImageTransfersServiceAdd) Send() (*ovirtsdk4.ImageTransfersServiceAddResponse, error)
Send return image transfer add response
type ImageTransfersServiceAddResponse ¶ added in v1.15.0
type ImageTransfersServiceAddResponse struct {
// contains filtered or unexported fields
}
ImageTransfersServiceAddResponse wraps ovirt add transfer service
func (*ImageTransfersServiceAddResponse) ImageTransfer ¶ added in v1.15.0
func (service *ImageTransfersServiceAddResponse) ImageTransfer() (*ovirtsdk4.ImageTransfer, bool)
ImageTransfer returns disk struct
type ImageTransfersServiceAddResponseInterface ¶ added in v1.15.0
type ImageTransfersServiceAddResponseInterface interface {
ImageTransfer() (*ovirtsdk4.ImageTransfer, bool)
}
ImageTransfersServiceAddResponseInterface defines service methods
type ImageTransfersServiceInterface ¶ added in v1.15.0
type ImageTransfersServiceInterface interface { Add() ImageTransferServiceAddInterface ImageTransferService(string) ImageTransferServiceInterface }
ImageTransfersServiceInterface defines service methods
type ImageTransfersServiceResponse ¶ added in v1.15.0
type ImageTransfersServiceResponse struct {
// contains filtered or unexported fields
}
ImageTransfersServiceResponse wraps ovirt add transfer service
func (*ImageTransfersServiceResponse) ImageTransfer ¶ added in v1.15.0
func (service *ImageTransfersServiceResponse) ImageTransfer(imageTransfer *ovirtsdk4.ImageTransfer) *ovirtsdk4.ImageTransfersServiceAddRequest
ImageTransfer sets image transfer and returns add request
func (*ImageTransfersServiceResponse) Send ¶ added in v1.15.0
func (service *ImageTransfersServiceResponse) Send() (ImageTransfersServiceAddResponseInterface, error)
Send returns disk get response
type ImageioDataSource ¶ added in v1.15.0
type ImageioDataSource struct {
// contains filtered or unexported fields
}
ImageioDataSource is the data provider for ovirt-imageio.
func NewImageioDataSource ¶ added in v1.15.0
func NewImageioDataSource(endpoint string, accessKey string, secKey string, certDir string, diskID string) (*ImageioDataSource, error)
NewImageioDataSource creates a new instance of the ovirt-imageio data provider.
func (*ImageioDataSource) Close ¶ added in v1.15.0
func (is *ImageioDataSource) Close() error
Close all readers.
func (*ImageioDataSource) GetURL ¶ added in v1.15.0
func (is *ImageioDataSource) GetURL() *url.URL
GetURL returns the URI that the data processor can use when converting the data.
func (*ImageioDataSource) Info ¶ added in v1.15.0
func (is *ImageioDataSource) Info() (ProcessingPhase, error)
Info is called to get initial information about the data.
func (*ImageioDataSource) Process ¶ added in v1.15.0
func (is *ImageioDataSource) Process() (ProcessingPhase, error)
Process is called to do any special processing before giving the URI to the data back to the processor
func (*ImageioDataSource) Transfer ¶ added in v1.15.0
func (is *ImageioDataSource) Transfer(path string) (ProcessingPhase, error)
Transfer is called to transfer the data from the source to a scratch location.
func (*ImageioDataSource) TransferFile ¶ added in v1.15.0
func (is *ImageioDataSource) TransferFile(fileName string) (ProcessingPhase, error)
TransferFile is called to transfer the data from the source to the passed in file.
type ProcessingPhase ¶ added in v1.8.0
type ProcessingPhase string
ProcessingPhase is the current phase being processed.
const ( // ProcessingPhaseInfo is the first phase, during this phase the source obtains information needed to determine which phase to go to next. ProcessingPhaseInfo ProcessingPhase = "Info" // ProcessingPhaseTransferScratch is the phase in which the data source writes data to the scratch space. ProcessingPhaseTransferScratch ProcessingPhase = "TransferScratch" // ProcessingPhaseTransferDataDir is the phase in which the data source writes data directly to the target path without conversion. ProcessingPhaseTransferDataDir ProcessingPhase = "TransferDataDir" // ProcessingPhaseTransferDataFile is the phase in which the data source writes data directly to the target file without conversion. ProcessingPhaseTransferDataFile ProcessingPhase = "TransferDataFile" // ProcessingPhaseValidatePause is the phase in which the data processor should validate and then pause. ProcessingPhaseValidatePause ProcessingPhase = "ValidatePause" // ProcessingPhaseProcess is the phase in which the data source processes the data just written to the scratch space. ProcessingPhaseProcess ProcessingPhase = "Process" // ProcessingPhaseConvert is the phase in which the data is taken from the url provided by the source, and it is converted to the target RAW disk image format. // The url can be an http end point or file system end point. ProcessingPhaseConvert ProcessingPhase = "Convert" // ProcessingPhaseResize the disk image, this is only needed when the target contains a file system (block device do not need a resize) ProcessingPhaseResize ProcessingPhase = "Resize" // ProcessingPhaseComplete is the phase where the entire process completed successfully and we can exit gracefully. ProcessingPhaseComplete ProcessingPhase = "Complete" // ProcessingPhasePause is the phase where we pause processing and end the loop, and expect something to call the process loop again. ProcessingPhasePause ProcessingPhase = "Pause" // ProcessingPhaseError is the phase in which we encountered an error and need to exit ungracefully. ProcessingPhaseError ProcessingPhase = "Error" )
type RegistryDataSource ¶ added in v1.8.0
type RegistryDataSource struct {
// contains filtered or unexported fields
}
RegistryDataSource is the struct containing the information needed to import from a registry data source. Sequence of phases: 1. Info -> Transfer 2. Transfer -> Process 3. Process -> Convert (In the process phase the container image layers are extracted, and the url is pointed to the file determined to be the disk image)
func NewRegistryDataSource ¶ added in v1.8.0
func NewRegistryDataSource(endpoint, accessKey, secKey, certDir string, insecureTLS bool) *RegistryDataSource
NewRegistryDataSource creates a new instance of the Registry Data Source.
func (*RegistryDataSource) Close ¶ added in v1.8.0
func (rd *RegistryDataSource) Close() error
Close closes any readers or other open resources.
func (*RegistryDataSource) GetURL ¶ added in v1.8.0
func (rd *RegistryDataSource) GetURL() *url.URL
GetURL returns the url that the data processor can use when converting the data.
func (*RegistryDataSource) Info ¶ added in v1.8.0
func (rd *RegistryDataSource) Info() (ProcessingPhase, error)
Info is called to get initial information about the data. No information available for registry currently.
func (*RegistryDataSource) Process ¶ added in v1.8.0
func (rd *RegistryDataSource) Process() (ProcessingPhase, error)
Process is called to do any special processing before giving the url to the data back to the processor
func (*RegistryDataSource) Transfer ¶ added in v1.8.0
func (rd *RegistryDataSource) Transfer(path string) (ProcessingPhase, error)
Transfer is called to transfer the data from the source registry to a temporary location.
func (*RegistryDataSource) TransferFile ¶ added in v1.8.0
func (rd *RegistryDataSource) TransferFile(fileName string) (ProcessingPhase, error)
TransferFile is called to transfer the data from the source to the passed in file.
type ResumableDataSource ¶ added in v1.13.0
type ResumableDataSource interface { DataSourceInterface GetResumePhase() ProcessingPhase }
ResumableDataSource is the interface all resumeable data sources should implement
type S3Client ¶ added in v1.8.0
type S3Client interface {
GetObject(input *s3.GetObjectInput) (*s3.GetObjectOutput, error)
}
S3Client is the interface to the used S3 client.
type S3DataSource ¶ added in v1.8.0
type S3DataSource struct {
// contains filtered or unexported fields
}
S3DataSource is the struct containing the information needed to import from an S3 data source. Sequence of phases: 1. Info -> Transfer 2. Transfer -> Process 3. Process -> Convert
func NewS3DataSource ¶ added in v1.8.0
func NewS3DataSource(endpoint, accessKey, secKey string) (*S3DataSource, error)
NewS3DataSource creates a new instance of the S3DataSource
func (*S3DataSource) Close ¶ added in v1.8.0
func (sd *S3DataSource) Close() error
Close closes any readers or other open resources.
func (*S3DataSource) GetURL ¶ added in v1.8.0
func (sd *S3DataSource) GetURL() *url.URL
GetURL returns the url that the data processor can use when converting the data.
func (*S3DataSource) Info ¶ added in v1.8.0
func (sd *S3DataSource) Info() (ProcessingPhase, error)
Info is called to get initial information about the data.
func (*S3DataSource) Process ¶ added in v1.8.0
func (sd *S3DataSource) Process() (ProcessingPhase, error)
Process is called to do any special processing before giving the url to the data back to the processor
func (*S3DataSource) Transfer ¶ added in v1.8.0
func (sd *S3DataSource) Transfer(path string) (ProcessingPhase, error)
Transfer is called to transfer the data from the source to a temporary location.
func (*S3DataSource) TransferFile ¶ added in v1.8.0
func (sd *S3DataSource) TransferFile(fileName string) (ProcessingPhase, error)
TransferFile is called to transfer the data from the source to the passed in file.
type SystemService ¶ added in v1.15.0
type SystemService struct {
// contains filtered or unexported fields
}
SystemService wraps ovirt system service
func (*SystemService) DisksService ¶ added in v1.15.0
func (service *SystemService) DisksService() DisksServiceInterface
DisksService returns disks service
func (*SystemService) ImageTransfersService ¶ added in v1.15.0
func (service *SystemService) ImageTransfersService() ImageTransfersServiceInterface
ImageTransfersService returns image service
type SystemServiceInteface ¶ added in v1.15.0
type SystemServiceInteface interface { DisksService() DisksServiceInterface ImageTransfersService() ImageTransfersServiceInterface }
SystemServiceInteface defines service methods
type UploadDataSource ¶ added in v1.8.0
type UploadDataSource struct {
// contains filtered or unexported fields
}
UploadDataSource contains all the information need to upload data into a data volume. Sequence of phases: 1a. ProcessingPhaseInfo -> ProcessingPhaseTransferScratch (In Info phase the format readers are configured) In case the readers don't contain a raw file. 1b. ProcessingPhaseInfo -> ProcessingPhaseTransferDataFile, in the case the readers contain a raw file. 2a. ProcessingPhaseTransferScratch -> ProcessingPhaseProcess 2b. ProcessingPhaseTransferDataFile -> ProcessingPhaseResize 3. ProcessingPhaseProcess -> ProcessingPhaseConvert
func NewUploadDataSource ¶ added in v1.8.0
func NewUploadDataSource(stream io.ReadCloser) *UploadDataSource
NewUploadDataSource creates a new instance of an UploadDataSource
func (*UploadDataSource) Close ¶ added in v1.8.0
func (ud *UploadDataSource) Close() error
Close closes any readers or other open resources.
func (*UploadDataSource) GetURL ¶ added in v1.8.0
func (ud *UploadDataSource) GetURL() *url.URL
GetURL returns the url that the data processor can use when converting the data.
func (*UploadDataSource) Info ¶ added in v1.8.0
func (ud *UploadDataSource) Info() (ProcessingPhase, error)
Info is called to get initial information about the data.
func (*UploadDataSource) Process ¶ added in v1.8.0
func (ud *UploadDataSource) Process() (ProcessingPhase, error)
Process is called to do any special processing before giving the url to the data back to the processor
func (*UploadDataSource) Transfer ¶ added in v1.8.0
func (ud *UploadDataSource) Transfer(path string) (ProcessingPhase, error)
Transfer is called to transfer the data from the source to the passed in path.
func (*UploadDataSource) TransferFile ¶ added in v1.8.0
func (ud *UploadDataSource) TransferFile(fileName string) (ProcessingPhase, error)
TransferFile is called to transfer the data from the source to the passed in file.
type VDDKDataSource ¶ added in v1.23.0
VDDKDataSource is the data provider for vddk. Currently just a reference to the nbdkit process.
func NewVDDKDataSource ¶ added in v1.23.0
func NewVDDKDataSource(endpoint string, accessKey string, secKey string, thumbprint string, uuid string, backingFile string) (*VDDKDataSource, error)
NewVDDKDataSource creates a new instance of the vddk data provider.
func (*VDDKDataSource) Close ¶ added in v1.23.0
func (vs *VDDKDataSource) Close() error
Close closes any readers or other open resources.
func (*VDDKDataSource) GetURL ¶ added in v1.23.0
func (vs *VDDKDataSource) GetURL() *url.URL
GetURL returns the url that the data processor can use when converting the data.
func (*VDDKDataSource) Info ¶ added in v1.23.0
func (vs *VDDKDataSource) Info() (ProcessingPhase, error)
Info is called to get initial information about the data.
func (*VDDKDataSource) Process ¶ added in v1.23.0
func (vs *VDDKDataSource) Process() (ProcessingPhase, error)
Process is called to do any special processing before giving the url to the data back to the processor
func (*VDDKDataSource) Transfer ¶ added in v1.23.0
func (vs *VDDKDataSource) Transfer(path string) (ProcessingPhase, error)
Transfer is called to transfer the data from the source to the path passed in.
func (*VDDKDataSource) TransferFile ¶ added in v1.23.0
func (vs *VDDKDataSource) TransferFile(fileName string) (ProcessingPhase, error)
TransferFile is called to transfer the data from the source to the file passed in.
type ValidationSizeError ¶ added in v1.21.0
type ValidationSizeError struct {
// contains filtered or unexported fields
}
ValidationSizeError is an error indication size validation failure.
func (ValidationSizeError) Error ¶ added in v1.21.0
func (e ValidationSizeError) Error() string