types

Documentation

Index

• Constants
• func EscapeJSONPointer(ptr string) string
• func GeneratePatchPayload(patches ...PatchOperation) ([]byte, error)
• func GenerateTestReplacePatch(path string, oldValue, newValue interface{}) ([]byte, error)
• func GetFilesystemOverhead(volumeMode *k8sv1.PersistentVolumeMode, storageClass *string, ...) cdiv1.Percent
• func GetSizeIncludingFSOverhead(size *resource.Quantity, storageClass *string, ...) (*resource.Quantity, error)
• func GetSizeIncludingGivenOverhead(size *resource.Quantity, overhead cdiv1.Percent) (*resource.Quantity, error)
• func HasSharedAccessMode(accessModes []k8sv1.PersistentVolumeAccessMode) 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 PVCNameFromVirtVolume(volume *virtv1.Volume) string
• func VirtVolumesToPVCMap(volumes []*virtv1.Volume, pvcStore cache.Store, namespace string) (map[string]*k8sv1.PersistentVolumeClaim, error)
• type CloneSource
  • func GetCloneSource(ctx context.Context, client kubecli.KubevirtClient, vm *virtv1.VirtualMachine, ...) (*CloneSource, error)
  • func GetCloneSourceWithInformers(vm *virtv1.VirtualMachine, dvSpec *cdiv1.DataVolumeSpec, ...) (*CloneSource, error)
• type PatchOperation
  • func UnmarshalPatch(patch []byte) ([]PatchOperation, error)

Constants

const (
	PatchReplaceOp = "replace"
	PatchTestOp    = "test"
	PatchAddOp     = "add"
)

const MiB = 1024 * 1024

Functions

func EscapeJSONPointer

func EscapeJSONPointer(ptr string) string

func GeneratePatchPayload

func GeneratePatchPayload(patches ...PatchOperation) ([]byte, error)

func GenerateTestReplacePatch

func GenerateTestReplacePatch(path string, oldValue, newValue interface{}) ([]byte, error)

func GetFilesystemOverhead

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

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 HasSharedAccessMode

func HasSharedAccessMode(accessModes []k8sv1.PersistentVolumeAccessMode) 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 PVCNameFromVirtVolume

func PVCNameFromVirtVolume(volume *virtv1.Volume) string

func VirtVolumesToPVCMap

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

Types

type CloneSource

type CloneSource struct {
	Namespace string
	Name      string
}

func GetCloneSource

func GetCloneSource(ctx context.Context, client kubecli.KubevirtClient, vm *virtv1.VirtualMachine, dvSpec *cdiv1.DataVolumeSpec) (*CloneSource, error)

func GetCloneSourceWithInformers

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

type PatchOperation

type PatchOperation struct {
	Op    string      `json:"op"`
	Path  string      `json:"path"`
	Value interface{} `json:"value"`
}

func UnmarshalPatch

func UnmarshalPatch(patch []byte) ([]PatchOperation, error)