imageupload

Documentation

Index

• Constants
• Variables
• func ConstructUploadProxyPath(uploadProxyURL string) (string, error)
• func ConstructUploadProxyPathAsync(uploadProxyURL, token string, insecure bool) (string, error)
• func NewImageUploadCommand(clientConfig clientcmd.ClientConfig) *cobra.Command
• func SetDefaultHTTPClientCreator()
• func SetHTTPClientCreator(f HTTPClientCreator)
• type HTTPClientCreator

Constants

const (
	// PodPhaseAnnotation is the annotation on a PVC containing the upload pod phase
	PodPhaseAnnotation = "cdi.kubevirt.io/storage.pod.phase"

	// PodReadyAnnotation tells whether the uploadserver pod is ready
	PodReadyAnnotation = "cdi.kubevirt.io/storage.pod.ready"

	UsePopulatorAnnotation = "cdi.kubevirt.io/storage.usePopulator"
	PVCPrimeNameAnnotation = "cdi.kubevirt.io/storage.populator.pvcPrime"

	//UploadProxyURIAsync is a URI of the upload proxy, the endpoint is asynchronous
	UploadProxyURIAsync = "/v1beta1/upload-async"

	//UploadProxyURI is a URI of the upload proxy, the endpoint is synchronous for backwards compatibility
	UploadProxyURI = "/v1beta1/upload"

	// ProvisioningFailed stores the 'ProvisioningFailed' event condition used for PVC error handling
	ProvisioningFailed = "ProvisioningFailed"
	// ErrClaimNotValid stores the 'ErrClaimNotValid' event condition used for DV error handling
	ErrClaimNotValid = "ErrClaimNotValid"

	// OptimisticLockErrorMsg is returned by kube-apiserver when trying to update an old version of a resource
	// https://github.com/kubernetes/kubernetes/blob/b89f564539fad77cd22de1b155d84638daf8c83f/staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go#L240
	OptimisticLockErrorMsg = "the object has been modified; please apply your changes to the latest version and try again"
)

Variables

var UploadProcessingCompleteFunc processingCompleteFunc = waitUploadProcessingComplete

UploadProcessingCompleteFunc the function called while determining if post transfer processing is complete.

Functions

func ConstructUploadProxyPath

func ConstructUploadProxyPath(uploadProxyURL string) (string, error)

ConstructUploadProxyPath - receives uploadproxy address and concatenates to it URI

func ConstructUploadProxyPathAsync

func ConstructUploadProxyPathAsync(uploadProxyURL, token string, insecure bool) (string, error)

ConstructUploadProxyPathAsync - receives uploadproxy address and concatenates to it URI

func NewImageUploadCommand

func NewImageUploadCommand(clientConfig clientcmd.ClientConfig) *cobra.Command

NewImageUploadCommand returns a cobra.Command for handling the uploading of VM images

func SetDefaultHTTPClientCreator

func SetDefaultHTTPClientCreator()

SetDefaultHTTPClientCreator sets the http client creator back to default

func SetHTTPClientCreator

func SetHTTPClientCreator(f HTTPClientCreator)

SetHTTPClientCreator allows overriding the default http client useful for unit tests

Types

type HTTPClientCreator

type HTTPClientCreator func(bool) *http.Client

HTTPClientCreator is a function that creates http clients