types

Documentation

Index

• Constants
• Variables
• func DataVolumeByNameFunc(dataVolumeInformer cache.SharedInformer, dataVolumes []*cdiv1.DataVolume) func(name string, namespace string) (*cdiv1.DataVolume, error)
• func DataVolumeFailed(dv *cdiv1.DataVolume) bool
• func DataVolumeWFFC(dv *cdiv1.DataVolume) bool
• func GenerateDataVolumeFromTemplate(clientset kubecli.KubevirtClient, ...) (*cdiv1.DataVolume, error)
• func GetDataVolumeFromCache(namespace, name string, dataVolumeInformer cache.SharedInformer) (*cdiv1.DataVolume, error)
• func GetFilesystemOverhead(volumeMode *k8sv1.PersistentVolumeMode, storageClass *string, ...) cdiv1.Percent
• func GetPVCsFromVolumes(volumes []virtv1.Volume) map[string]string
• func GetPersistentVolumeClaimFromCache(namespace, name string, pvcInformer cache.SharedInformer) (*k8sv1.PersistentVolumeClaim, error)
• func GetSizeIncludingDefaultFSOverhead(size *resource.Quantity) (*resource.Quantity, error)
• func GetSizeIncludingFSOverhead(size *resource.Quantity, storageClass *string, ...) (*resource.Quantity, error)
• func GetSizeIncludingGivenOverhead(size *resource.Quantity, overhead cdiv1.Percent) (*resource.Quantity, error)
• func HasDataVolumeErrors(namespace string, volumes []virtv1.Volume, ...) error
• func HasDataVolumeProvisioning(namespace string, volumes []virtv1.Volume, ...) bool
• func HasFailedDataVolumes(dvs []*cdiv1.DataVolume) bool
• func HasSharedAccessMode(accessModes []k8sv1.PersistentVolumeAccessMode) bool
• func HasUnboundPVC(namespace string, volumes []virtv1.Volume, pvcInformer cache.SharedInformer) bool
• func HasWFFCDataVolumes(dvs []*cdiv1.DataVolume) bool
• func IsPVCBlock(volumeMode *k8sv1.PersistentVolumeMode) bool
• func IsPVCBlockFromStore(store cache.Store, namespace string, claimName string) (pvc *k8sv1.PersistentVolumeClaim, exists bool, isBlockDevice bool, err error)
• func IsPreallocated(annotations map[string]string) bool
• func IsReadOnlyAccessMode(accessModes []k8sv1.PersistentVolumeAccessMode) bool
• func ListDataVolumesFromTemplates(namespace string, dvTemplates []virtv1.DataVolumeTemplateSpec, ...) ([]*cdiv1.DataVolume, error)
• func ListDataVolumesFromVolumes(namespace string, volumes []virtv1.Volume, ...) ([]*cdiv1.DataVolume, error)
• func PVCNameFromVirtVolume(volume *virtv1.Volume) string
• func RenderPVC(size *resource.Quantity, claimName, namespace, storageClass, accessMode string, ...) *k8sv1.PersistentVolumeClaim
• func VirtVolumesToPVCMap(volumes []*virtv1.Volume, pvcStore cache.Store, namespace string) (map[string]*k8sv1.PersistentVolumeClaim, error)
• func VolumeReadyToAttachToNode(namespace string, volume virtv1.Volume, dataVolumes []*cdiv1.DataVolume, ...) (bool, bool, error)
• type CloneSource
  • func GetCloneSource(ctx context.Context, client kubecli.KubevirtClient, namespace string, ...) (*CloneSource, error)
  • func GetCloneSourceWithInformers(vm *virtv1.VirtualMachine, dvSpec *cdiv1.DataVolumeSpec, ...) (*CloneSource, error)
• type DataVolumeConditionManager
  • func NewDataVolumeConditionManager() *DataVolumeConditionManager
  • func (d *DataVolumeConditionManager) GetCondition(dv *cdiv1.DataVolume, cond cdiv1.DataVolumeConditionType) *cdiv1.DataVolumeCondition
  • func (d *DataVolumeConditionManager) HasCondition(dv *cdiv1.DataVolume, cond cdiv1.DataVolumeConditionType) bool
  • func (d *DataVolumeConditionManager) HasConditionWithStatus(dv *cdiv1.DataVolume, cond cdiv1.DataVolumeConditionType, ...) bool
  • func (d *DataVolumeConditionManager) HasConditionWithStatusAndReason(dv *cdiv1.DataVolume, cond cdiv1.DataVolumeConditionType, ...) bool
• type PvcNotFoundError
  • func (e PvcNotFoundError) Error() string

Constants

const (
	ConfigName        = "config"
	DefaultFSOverhead = cdiv1.Percent("0.055")
	FSOverheadMsg     = "Using default 5.5%% filesystem overhead for pvc size"
)

const MiB = 1024 * 1024

Variables

var ErrFailedToFindCdi error = errors.New("No CDI instances found")

var ErrMultipleCdiInstances error = errors.New("Detected more than one CDI instance")

Functions

func DataVolumeByNameFunc

func DataVolumeByNameFunc(dataVolumeInformer cache.SharedInformer, dataVolumes []*cdiv1.DataVolume) func(name string, namespace string) (*cdiv1.DataVolume, error)

func DataVolumeFailed

func DataVolumeFailed(dv *cdiv1.DataVolume) bool

func DataVolumeWFFC

func DataVolumeWFFC(dv *cdiv1.DataVolume) bool

func GenerateDataVolumeFromTemplate

func GenerateDataVolumeFromTemplate(clientset kubecli.KubevirtClient, dataVolumeTemplate virtv1.DataVolumeTemplateSpec, namespace, priorityClassName string) (*cdiv1.DataVolume, error)

func GetDataVolumeFromCache

func GetDataVolumeFromCache(namespace, name string, dataVolumeInformer cache.SharedInformer) (*cdiv1.DataVolume, error)

func GetFilesystemOverhead

func GetFilesystemOverhead(volumeMode *k8sv1.PersistentVolumeMode, storageClass *string, cdiConfig *cdiv1.CDIConfig) cdiv1.Percent

func GetPVCsFromVolumes

func GetPVCsFromVolumes(volumes []virtv1.Volume) map[string]string

func GetPersistentVolumeClaimFromCache

func GetPersistentVolumeClaimFromCache(namespace, name string, pvcInformer cache.SharedInformer) (*k8sv1.PersistentVolumeClaim, error)

func GetSizeIncludingDefaultFSOverhead

func GetSizeIncludingDefaultFSOverhead(size *resource.Quantity) (*resource.Quantity, error)

func GetSizeIncludingFSOverhead

func GetSizeIncludingFSOverhead(size *resource.Quantity, storageClass *string, volumeMode *k8sv1.PersistentVolumeMode, cdiConfig *cdiv1.CDIConfig) (*resource.Quantity, error)

func GetSizeIncludingGivenOverhead

func GetSizeIncludingGivenOverhead(size *resource.Quantity, overhead cdiv1.Percent) (*resource.Quantity, error)

func HasDataVolumeErrors

func HasDataVolumeErrors(namespace string, volumes []virtv1.Volume, dataVolumeInformer cache.SharedInformer) error

func HasDataVolumeProvisioning

func HasDataVolumeProvisioning(namespace string, volumes []virtv1.Volume, dataVolumeInformer cache.SharedInformer) bool

func HasFailedDataVolumes

func HasFailedDataVolumes(dvs []*cdiv1.DataVolume) bool

func HasSharedAccessMode

func HasSharedAccessMode(accessModes []k8sv1.PersistentVolumeAccessMode) bool

func HasUnboundPVC

func HasUnboundPVC(namespace string, volumes []virtv1.Volume, pvcInformer cache.SharedInformer) bool

func HasWFFCDataVolumes

func HasWFFCDataVolumes(dvs []*cdiv1.DataVolume) bool

func IsPVCBlock

func IsPVCBlock(volumeMode *k8sv1.PersistentVolumeMode) bool

func IsPVCBlockFromStore

func IsPVCBlockFromStore(store cache.Store, namespace string, claimName string) (pvc *k8sv1.PersistentVolumeClaim, exists bool, isBlockDevice bool, err error)

func IsPreallocated

func IsPreallocated(annotations map[string]string) bool

func IsReadOnlyAccessMode

func IsReadOnlyAccessMode(accessModes []k8sv1.PersistentVolumeAccessMode) bool

func ListDataVolumesFromTemplates

func ListDataVolumesFromTemplates(namespace string, dvTemplates []virtv1.DataVolumeTemplateSpec, dataVolumeInformer cache.SharedInformer) ([]*cdiv1.DataVolume, error)

func ListDataVolumesFromVolumes

func ListDataVolumesFromVolumes(namespace string, volumes []virtv1.Volume, dataVolumeInformer cache.SharedInformer, pvcInformer cache.SharedInformer) ([]*cdiv1.DataVolume, error)

func PVCNameFromVirtVolume

func PVCNameFromVirtVolume(volume *virtv1.Volume) string

func RenderPVC

func RenderPVC(size *resource.Quantity, claimName, namespace, storageClass, accessMode string, blockVolume bool) *k8sv1.PersistentVolumeClaim

func VirtVolumesToPVCMap

func VirtVolumesToPVCMap(volumes []*virtv1.Volume, pvcStore cache.Store, namespace string) (map[string]*k8sv1.PersistentVolumeClaim, error)

func VolumeReadyToAttachToNode

func VolumeReadyToAttachToNode(namespace string, volume virtv1.Volume, dataVolumes []*cdiv1.DataVolume, dataVolumeInformer, pvcInformer cache.SharedInformer) (bool, bool, error)

Types

type CloneSource

type CloneSource struct {
	Namespace string
	Name      string
}

func GetCloneSource

func GetCloneSource(ctx context.Context, client kubecli.KubevirtClient, namespace string, dvSpec *cdiv1.DataVolumeSpec) (*CloneSource, error)

func GetCloneSourceWithInformers

func GetCloneSourceWithInformers(vm *virtv1.VirtualMachine, dvSpec *cdiv1.DataVolumeSpec, dataSourceInformer cache.SharedInformer) (*CloneSource, error)

type DataVolumeConditionManager

type DataVolumeConditionManager struct {
}

func NewDataVolumeConditionManager

func NewDataVolumeConditionManager() *DataVolumeConditionManager

func (*DataVolumeConditionManager) GetCondition

func (d *DataVolumeConditionManager) GetCondition(dv *cdiv1.DataVolume, cond cdiv1.DataVolumeConditionType) *cdiv1.DataVolumeCondition

func (*DataVolumeConditionManager) HasCondition

func (d *DataVolumeConditionManager) HasCondition(dv *cdiv1.DataVolume, cond cdiv1.DataVolumeConditionType) bool

func (*DataVolumeConditionManager) HasConditionWithStatus

func (d *DataVolumeConditionManager) HasConditionWithStatus(dv *cdiv1.DataVolume, cond cdiv1.DataVolumeConditionType, status v1.ConditionStatus) bool

func (*DataVolumeConditionManager) HasConditionWithStatusAndReason

func (d *DataVolumeConditionManager) HasConditionWithStatusAndReason(dv *cdiv1.DataVolume, cond cdiv1.DataVolumeConditionType, status v1.ConditionStatus, reason string) bool

type PvcNotFoundError

type PvcNotFoundError struct {
	Reason string
}

func (PvcNotFoundError) Error

func (e PvcNotFoundError) Error() string