common

package

Go to main page

Versions in this module

v1

v1.60.3

Sep 11, 2024

Changes in this version

+ func IsLost(pvc *corev1.PersistentVolumeClaim) bool

v1.60.2

Aug 22, 2024

v1.60.1

Aug 18, 2024

v1.60.0

Aug 18, 2024

Changes in this version

+ func CopyAllowedAnnotations(srcObj, dstObj metav1.Object)

+ func CopyAllowedLabels(srcLabels map[string]string, dstObj metav1.Object, overwrite bool)

+ func IsSnapshotValidForClone(sourceSnapshot *snapshotv1.VolumeSnapshot) error

v1.59.1

Aug 22, 2024

v1.59.0

Apr 1, 2024

Changes in this version

+ const AnnCdiCustomizeComponentHash

+ const AnnPodSidecarInjectionIstio

+ const AnnPodSidecarInjectionIstioDefault

+ const AnnPodSidecarInjectionLinkerd

+ const AnnPodSidecarInjectionLinkerdDefault

v1.58.4

Aug 20, 2024

Changes in this version

+ const AnnRequiresDirectIO

+ const AnnSourceVolumeMode

+ const OOMKilledReason

+ func IsDataVolumeUsingDefaultStorageClass(dv *cdiv1.DataVolume) bool

v1.58.3

Mar 21, 2024

Changes in this version

+ const AnnCreatedForDataVolume

v1.58.2

Mar 19, 2024

Changes in this version

+ const AnnAllowClaimAdoption

+ const AnnGarbageCollected

+ func AllowClaimAdoption(c client.Client, pvc *corev1.PersistentVolumeClaim, dv *cdiv1.DataVolume) (bool, error)

+ func ClaimIsPopulatedForDataVolume(pvc *corev1.PersistentVolumeClaim, dv *cdiv1.DataVolume) bool

+ func ClaimMayExistBeforeDataVolume(c client.Client, pvc *corev1.PersistentVolumeClaim, dv *cdiv1.DataVolume) (bool, error)

v1.58.1

Jan 31, 2024

Changes in this version

+ func GetStorageClassFromDVSpec(dv *cdiv1.DataVolume) *string

v1.58.0

Nov 21, 2023

Changes in this version

+ const AnnDefaultSnapshotClass

+ const AnnDefaultVirtStorageClass

+ const ImportPaused

+ const MessageDefaultVolumeSnapshotClassSelected

+ const MessageFirstVolumeSnapshotClassSelected

+ const MessageImportPaused

+ const MessageStorageProfileVolumeSnapshotClassSelected

+ const VolumeSnapshotClassSelected

+ var DefaultInstanceTypeLabels = []string

+ func GetPlatformDefaultStorageClass(ctx context.Context, storageClasses *storagev1.StorageClassList, ...) *storagev1.StorageClass

+ func GetPodFromPvc(c client.Client, namespace string, pvc *corev1.PersistentVolumeClaim) (*corev1.Pod, error)

+ func GetStorageClassByNameWithK8sFallback(ctx context.Context, client client.Client, name *string) (*storagev1.StorageClass, error)

+ func GetStorageClassByNameWithVirtFallback(ctx context.Context, client client.Client, name *string, ...) (*storagev1.StorageClass, error)

+ func GetVolumeSnapshotClass(ctx context.Context, c client.Client, pvc *corev1.PersistentVolumeClaim, ...) (*string, error)

+ func IsMultiStageImportInProgress(pvc *corev1.PersistentVolumeClaim) bool

+ func MaybeSetPvcMultiStageAnnotation(pvc *corev1.PersistentVolumeClaim, args *CheckpointArgs) error

+ func UpdatesMultistageImportSucceeded(pvc *corev1.PersistentVolumeClaim, args *CheckpointArgs) error

+ type CheckpointArgs struct

+ Checkpoints []cdiv1.DataVolumeCheckpoint

+ Client client.Client

+ IsFinal bool

+ Log logr.Logger

+ type CheckpointRecord struct

+ IsFinal bool

+ func GetNextCheckpoint(pvc *corev1.PersistentVolumeClaim, args *CheckpointArgs) *CheckpointRecord

v1.58.0-rc1

Oct 27, 2023

v1.57.0

Aug 15, 2023

Changes in this version

+ const AnnCloneSourcePod

+ const AnnCloneType

+ const AnnEventSource

+ const AnnEventSourceKind

+ const AnnPopulatorKind

+ const AnnPopulatorProgress

+ const AnnSelectedNode

+ const AnnUsePopulator

+ const LabelDynamicCredentialSupport

+ const ProgressDone

+ const SourceGCS

+ func AddImmediateBindingAnnotationIfWFFCDisabled(obj metav1.Object, gates featuregates.FeatureGates) error

+ func BuildHTTPClient(httpClient *http.Client) *http.Client

+ func BulkDeleteResources(ctx context.Context, c client.Client, obj client.ObjectList, ...) error

+ func ErrConnectionRefused(err error) bool

+ func GetAnnotatedEventSource(ctx context.Context, c client.Client, obj client.Object) (client.Object, error)

+ func GetCloneSourceInfo(dv *cdiv1.DataVolume) (sourceType, sourceName, sourceNamespace string)

+ func GetImagePullSecrets(client client.Client) ([]corev1.LocalObjectReference, error)

+ func GetMetricsURL(pod *corev1.Pod) (string, error)

+ func GetPVCContentType(pvc *corev1.PersistentVolumeClaim) string

+ func GetPodMetricsPort(pod *corev1.Pod) (int, error)

+ func GetProgressReportFromURL(url string, regExp *regexp.Regexp, httpClient *http.Client) (string, error)

+ func GetRequiredSpace(filesystemOverhead float64, requestedSpace int64) int64

+ func GetResource(ctx context.Context, c client.Client, namespace, name string, ...) (bool, error)

+ func GetSnapshotClassForSmartClone(dvName string, targetPvcStorageClassName *string, log logr.Logger, ...) (string, error)

+ func ImmediateBindingRequested(obj metav1.Object) bool

+ func InflateSizeWithOverhead(ctx context.Context, c client.Client, imgSize int64, ...) (resource.Quantity, error)

+ func IsBound(pvc *corev1.PersistentVolumeClaim) bool

+ func IsImageStream(pvc *corev1.PersistentVolumeClaim) bool

+ func IsPVBoundToPVC(pv *corev1.PersistentVolume, pvc *corev1.PersistentVolumeClaim) bool

+ func IsSnapshotReady(snapshot *snapshotv1.VolumeSnapshot) bool

+ func IsUnbound(pvc *corev1.PersistentVolumeClaim) bool

+ func OwnedByDataVolume(obj metav1.Object) bool

+ func ProgressFromClaim(ctx context.Context, args *ProgressFromClaimArgs) (string, error)

+ func Rebind(ctx context.Context, c client.Client, ...) error

+ func SetNodeNameIfPopulator(pvc *corev1.PersistentVolumeClaim, podSpec *corev1.PodSpec)

+ func SetPvcAllowedAnnotations(obj metav1.Object, pvc *corev1.PersistentVolumeClaim)

+ func ShouldIgnorePod(pod *corev1.Pod, pvc *corev1.PersistentVolumeClaim) bool

+ func UpdateGCSAnnotations(annotations map[string]string, gcs *cdiv1.DataVolumeSourceGCS)

+ func UpdateHTTPAnnotations(annotations map[string]string, http *cdiv1.DataVolumeSourceHTTP)

+ func UpdateImageIOAnnotations(annotations map[string]string, imageio *cdiv1.DataVolumeSourceImageIO)

+ func UpdateRegistryAnnotations(annotations map[string]string, registry *cdiv1.DataVolumeSourceRegistry)

+ func UpdateS3Annotations(annotations map[string]string, s3 *cdiv1.DataVolumeSourceS3)

+ func UpdateVDDKAnnotations(annotations map[string]string, vddk *cdiv1.DataVolumeSourceVDDK)

+ func ValidateSnapshotCloneProvisioners(ctx context.Context, c client.Client, snapshot *snapshotv1.VolumeSnapshot, ...) (bool, error)

+ func ValidateSnapshotCloneSize(snapshot *snapshotv1.VolumeSnapshot, pvcSpec *corev1.PersistentVolumeClaimSpec, ...) (bool, error)

+ type MultiTokenValidator struct

+ LongTokenValidator token.Validator

+ ShortTokenValidator token.Validator

+ func NewMultiTokenValidator(key *rsa.PublicKey) *MultiTokenValidator

+ func (mtv *MultiTokenValidator) ValidatePVC(source, target *corev1.PersistentVolumeClaim) error

+ func (mtv *MultiTokenValidator) ValidatePopulator(vcs *cdiv1.VolumeCloneSource, pvc *corev1.PersistentVolumeClaim) error

+ type PatchArgs struct

+ Client client.Client

+ Log logr.Logger

+ Obj client.Object

+ OldObj client.Object

+ type ProgressFromClaimArgs struct

+ Claim *corev1.PersistentVolumeClaim

+ Client client.Client

+ HTTPClient *http.Client

+ OwnerUID string

+ PodName string

+ PodNamespace string

v1.57.0-rc1

Jul 10, 2023

v1.57.0-alpha1

May 26, 2023

v1.56.1

Jul 31, 2023

v1.56.0

Mar 3, 2023

Changes in this version

+ const AnnAPIGroup

+ const AnnBackingFile

+ const AnnBoundCondition

+ const AnnBoundConditionMessage

+ const AnnBoundConditionReason

+ const AnnCertConfigMap

+ const AnnCheckStaticVolume

+ const AnnCheckpointsCopied

+ const AnnCloneOf

+ const AnnCloneRequest

+ const AnnCloneToken

+ const AnnContentType

+ const AnnCreatedBy

+ const AnnCurrentCheckpoint

+ const AnnCurrentPodID

+ const AnnDefaultStorageClass

+ const AnnDeleteAfterCompletion

+ const AnnDiskID

+ const AnnEndpoint

+ const AnnExtendedCloneToken

+ const AnnExternalPopulation

+ const AnnExtraHeaders

+ const AnnFinalCheckpoint

+ const AnnImmediateBinding

+ const AnnImportPod

+ const AnnMultiStageImportDone

+ const AnnOpenShiftImageLookup

+ const AnnOwnerUID

+ const AnnPermissiveClone

+ const AnnPersistentVolumeList

+ const AnnPodMultusDefaultNetwork

+ const AnnPodNetwork

+ const AnnPodPhase

+ const AnnPodReady

+ const AnnPodRestarts

+ const AnnPodRetainAfterCompletion

+ const AnnPodSidecarInjection

+ const AnnPodSidecarInjectionDefault

+ const AnnPopulatedFor

+ const AnnPrePopulated

+ const AnnPreallocationApplied

+ const AnnPreallocationRequested

+ const AnnPreviousCheckpoint

+ const AnnPriorityClassName

+ const AnnRegistryImageStream

+ const AnnRegistryImportMethod

+ const AnnRequiresScratch

+ const AnnRunningCondition

+ const AnnRunningConditionMessage

+ const AnnRunningConditionReason

+ const AnnSecret

+ const AnnSecretExtraHeaders

+ const AnnSource

+ const AnnSourceRunningCondition

+ const AnnSourceRunningConditionMessage

+ const AnnSourceRunningConditionReason

+ const AnnThumbprint

+ const AnnUUID

+ const AnnUploadRequest

+ const AnnVddkHostConnection

+ const AnnVddkInitImageURL

+ const AnnVddkVersion

+ const ClaimLost

+ const CloneComplete

+ const CloneSourceInUse

+ const CloneUniqueID

+ const DataVolName

+ const ErrBadArguments

+ const ErrBadTermFile

+ const ErrClaimNotValid

+ const ErrExceededQuota

+ const ErrIncompatiblePVC

+ const ErrInvalidFile

+ const ErrInvalidPath

+ const ErrStartingPod

+ const ErrUnknown

+ const LabelDefaultInstancetype

+ const LabelDefaultInstancetypeKind

+ const LabelDefaultPreference

+ const LabelDefaultPreferenceKind

+ const MessageErrStartingPod

+ const NoErr

+ const NotFound

+ const ScratchVolName

+ const SourceGlance

+ const SourceHTTP

+ const SourceImageio

+ const SourceNone

+ const SourceRegistry

+ const SourceS3

+ const SourceVDDK

+ var BlockMode = corev1.PersistentVolumeBlock

+ var FilesystemMode = corev1.PersistentVolumeFilesystem

+ func AddAnnotation(obj metav1.Object, key, value string)

+ func AddFinalizer(obj metav1.Object, name string)

+ func AddImportVolumeMounts() []corev1.VolumeMount

+ func AddLabel(obj metav1.Object, key, value string)

+ func AddVolumeDevices() []v1.VolumeDevice

+ func CreateClient(objs ...runtime.Object) client.Client

+ func CreateCloneSourcePodName(targetPvc *corev1.PersistentVolumeClaim) string

+ func CreateImporterTestPod(pvc *corev1.PersistentVolumeClaim, dvname string, ...) *corev1.Pod

+ func CreatePvc(name, ns string, annotations, labels map[string]string) *v1.PersistentVolumeClaim

+ func CreatePvcInStorageClass(name, ns string, storageClassName *string, ...) *v1.PersistentVolumeClaim

+ func CreateStorageClass(name string, annotations map[string]string) *storagev1.StorageClass

+ func CreateStorageClassWithProvisioner(name string, annotations, labels map[string]string, provisioner string) *storagev1.StorageClass

+ func ErrQuotaExceeded(err error) bool

+ func GetAPIServerKey() *rsa.PrivateKey

+ func GetActiveCDI(c client.Client) (*cdiv1.CDI, error)

+ func GetCloneSourceNameAndNamespace(dv *cdiv1.DataVolume) (name, namespace string)

+ func GetContentType(pvc *corev1.PersistentVolumeClaim) string

+ func GetDataVolumeTTLSeconds(config *cdiv1.CDIConfig) int32

+ func GetDefaultPodResourceRequirements(client client.Client) (*v1.ResourceRequirements, error)

+ func GetDefaultStorageClass(client client.Client) (*storagev1.StorageClass, error)

+ func GetEndpoint(pvc *corev1.PersistentVolumeClaim) (string, error)

+ func GetFilesystemOverheadForStorageClass(client client.Client, storageClassName *string) (cdiv1.Percent, error)

+ func GetNamespace(namespace, defaultNamespace string) string

+ func GetPodsUsingPVCs(c client.Client, namespace string, names sets.String, allowReadOnly bool) ([]v1.Pod, error)

+ func GetPreallocation(client client.Client, dataVolume *cdiv1.DataVolume) bool

+ func GetPriorityClass(pvc *v1.PersistentVolumeClaim) string

+ func GetRequestedImageSize(pvc *v1.PersistentVolumeClaim) (string, error)

+ func GetSource(pvc *corev1.PersistentVolumeClaim) string

+ func GetStorageClassByName(client client.Client, name *string) (*storagev1.StorageClass, error)

+ func GetVolumeMode(pvc *v1.PersistentVolumeClaim) v1.PersistentVolumeMode

+ func GetWorkloadNodePlacement(c client.Client) (*sdkapi.NodePlacement, error)

+ func HandleFailedPod(err error, podName string, pvc *v1.PersistentVolumeClaim, ...) error

+ func HasFinalizer(object metav1.Object, value string) bool

+ func IgnoreIsNoMatchError(err error) error

+ func IgnoreNotFound(err error) error

+ func IsErrCacheNotStarted(err error) bool

+ func IsPVCComplete(pvc *v1.PersistentVolumeClaim) bool

+ func IsPopulated(pvc *v1.PersistentVolumeClaim, c client.Client) (bool, error)

+ func IsWaitForFirstConsumerEnabled(obj metav1.Object, gates featuregates.FeatureGates) (bool, error)

+ func MakeEmptyCDICR() *cdiv1.CDI

+ func MakeEmptyCDIConfigSpec(name string) *cdiv1.CDIConfig

+ func NewCloneTokenValidator(issuer string, key *rsa.PublicKey) token.Validator

+ func NewImportDataVolume(name string) *cdiv1.DataVolume

+ func RemoveFinalizer(obj metav1.Object, name string)

+ func SetRestrictedSecurityContext(podSpec *v1.PodSpec)

+ func ShouldDeletePod(pvc *v1.PersistentVolumeClaim) bool

+ func ValidateClone(sourcePVC *v1.PersistentVolumeClaim, spec *cdiv1.DataVolumeSpec) error

+ func ValidateCloneTokenDV(validator token.Validator, dv *cdiv1.DataVolume) error

+ func ValidateCloneTokenPVC(t string, v token.Validator, source, target *v1.PersistentVolumeClaim) error

+ func ValidateRequestedCloneSize(sourceResources corev1.ResourceRequirements, ...) error

+ func ValidateSnapshotClone(sourceSnapshot *snapshotv1.VolumeSnapshot, spec *cdiv1.DataVolumeSpec) error

+ type FakeValidator struct

+ Match string

+ Name string

+ Namespace string

+ Operation token.Operation

+ Params map[string]string

+ Resource metav1.GroupVersionResource

+ func (v *FakeValidator) Validate(value string) (*token.Payload, error)

v1.56.0-rc0

Feb 21, 2023

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL