Versions in this module Expand all Collapse all v0 v0.9.1 Apr 16, 2024 Changes in this version + const PrefixedVGSecretNameKey + const PrefixedVGSecretNamespaceKey + const VGAsPrefix + const VGFinalizer + const VGNamePrefix + const VgcFinalizer + var FinalizerPredicate = predicate.Funcs + var PvcPredicate = predicate.Funcs + func CreateRequests(client runtimeclient.Client) handler.EventHandler + func CreateSuccessVGCEvent(logger logr.Logger, client client.Client, ...) error + func CreateVGC(client client.Client, logger logr.Logger, ...) error + func DeletePVCsUnderVGC(logger logr.Logger, client client.Client, ...) error + func GenerateVGC(vgname string, instance *volumegroupv1.VolumeGroup, ...) *volumegroupv1.VolumeGroupContent + func GetBoolField(object interface{}, fieldName string) bool + func GetCurrentTime() *metav1.Time + func GetObjectField(object interface{}, fieldName string) reflect.Value + func GetPVC(logger logr.Logger, client runtimeclient.Client, name, namespace string) (*corev1.PersistentVolumeClaim, error) + func GetPVCClass(claim *corev1.PersistentVolumeClaim) (string, error) + func GetStringField(object interface{}, fieldName string) string + func GetVG(client client.Client, logger logr.Logger, vgName string, vgNamespace string) (*volumegroupv1.VolumeGroup, error) + func GetVGC(client client.Client, logger logr.Logger, vgcName string, vgcNamespace string) (*volumegroupv1.VolumeGroupContent, error) + func GetVGClass(client client.Client, logger logr.Logger, vgClassName string) (*volumegroupv1.VolumeGroupClass, error) + func IsContainOtherFinalizers(object runtimeclient.Object, logger logr.Logger) bool + func IsPVCInPVCList(pvc *corev1.PersistentVolumeClaim, pvcList []corev1.PersistentVolumeClaim) bool + func IsPVCListEqual(x []corev1.PersistentVolumeClaim, y []corev1.PersistentVolumeClaim) bool + func IsPVCNeedToBeHandled(reqLogger logr.Logger, pvc *corev1.PersistentVolumeClaim, ...) (bool, error) + func IsVgExist(client client.Client, logger logr.Logger, ...) (bool, error) + func MakeVGName(prefix string, vgUID string) (string, error) + func ModifyVG(logger logr.Logger, client client.Client, vg *volumegroupv1.VolumeGroup, ...) error + func ModifyVolumesInVG(logger logr.Logger, client client.Client, vgClient grpcClient.VolumeGroup, ...) error + func UpdatePvcAndPvList(logger logr.Logger, vg *volumegroupv1.VolumeGroup, client client.Client, ...) error + func UpdateStaticVGCFromVG(client client.Client, vg *volumegroupv1.VolumeGroup, ...) error + func UpdateThinVGC(client client.Client, vgcNamespace, vgcName string, logger logr.Logger) error + func UpdateVGCByResponse(client client.Client, vgc *volumegroupv1.VolumeGroupContent, ...) error + func UpdateVGCStatus(client client.Client, logger logr.Logger, ...) error + func UpdateVGCStatusError(client client.Client, vgc *volumegroupv1.VolumeGroupContent, ...) error + func UpdateVGSourceContent(client client.Client, instance *volumegroupv1.VolumeGroup, vgcName string, ...) error + func UpdateVGStatus(client client.Client, vg *volumegroupv1.VolumeGroup, vgcName string, ...) error + func UpdateVGStatusError(client client.Client, vg *volumegroupv1.VolumeGroup, logger logr.Logger, ...) error v0.9.0 Jan 24, 2023 Changes in this version + const APIVersion + const PrefixedVolumeGroupSecretNameKey + const PrefixedVolumeGroupSecretNamespaceKey + const VolumeGroupAsPrefix + const VolumeGroupFinalizer + const VolumeGroupNamePrefix + func AddFinalizerToPVC(client runtimeclient.Client, logger logr.Logger, ...) error + func AddFinalizerToVG(client runtimeclient.Client, logger logr.Logger, vg *volumegroupv1.VolumeGroup) error + func AddFinalizerToVGC(client runtimeclient.Client, logger logr.Logger, ...) error + func AddMatchingPVToMatchingVGC(logger logr.Logger, client client.Client, pvc *corev1.PersistentVolumeClaim, ...) error + func AddPVCToVG(logger logr.Logger, client client.Client, pvc *corev1.PersistentVolumeClaim, ...) error + func AddVolumeToPvcListAndPvList(logger logr.Logger, client client.Client, pvc *corev1.PersistentVolumeClaim, ...) error + func AddVolumesToVolumeGroup(logger logr.Logger, client client.Client, vgClient grpcClient.VolumeGroup, ...) error + func Contains(slice []string, s string) bool + func CreateVolumeGroupContent(client client.Client, logger logr.Logger, ...) error + func FilterPrefixedParameters(prefix string, param map[string]string) map[string]string + func GenerateVolumeGroupContent(vgname string, instance *volumegroupv1.VolumeGroup, ...) *volumegroupv1.VolumeGroupContent + func GetMessageFromError(err error) string + func GetPVCList(logger logr.Logger, client runtimeclient.Client, driver string) (corev1.PersistentVolumeClaimList, error) + func GetPVFromPVC(logger logr.Logger, client client.Client, pvc *corev1.PersistentVolumeClaim) (*corev1.PersistentVolume, error) + func GetPersistentVolumeClaim(logger logr.Logger, client runtimeclient.Client, name, namespace string) (*corev1.PersistentVolumeClaim, error) + func GetPersistentVolumeClaimClass(claim *corev1.PersistentVolumeClaim) (string, error) + func GetSecretCred(vgcObj *volumegroupv1.VolumeGroupClass) (string, string) + func GetSecretDataFromClass(client client.Client, vgcObj *volumegroupv1.VolumeGroupClass, ...) (map[string]string, error) + func GetVGList(logger logr.Logger, client client.Client, driver string) (volumegroupv1.VolumeGroupList, error) + func GetVolumeGroupClass(client client.Client, logger logr.Logger, vgcName string) (*volumegroupv1.VolumeGroupClass, error) + func GetVolumeGroupContent(client client.Client, logger logr.Logger, volumeGroupContentName string, ...) (*volumegroupv1.VolumeGroupContent, error) + func HandleErrorMessage(logger logr.Logger, client client.Client, vg *volumegroupv1.VolumeGroup, ...) error + func HandlePVCErrorMessage(logger logr.Logger, client client.Client, pvc *corev1.PersistentVolumeClaim, ...) error + func HandleSuccessMessage(logger logr.Logger, client client.Client, vg *volumegroupv1.VolumeGroup, ...) error + func HandleVGCErrorMessage(logger logr.Logger, client client.Client, ...) error + func IsPVCCanBeAddedToVG(logger logr.Logger, client runtimeclient.Client, ...) error + func IsPVCHasMatchingDriver(logger logr.Logger, client runtimeclient.Client, ...) (bool, error) + func IsPVCInStaticVG(logger logr.Logger, client runtimeclient.Client, ...) (bool, error) + func IsPVCMatchesVG(logger logr.Logger, client client.Client, pvc *corev1.PersistentVolumeClaim, ...) (bool, error) + func IsPVCPartAnyVG(pvc *corev1.PersistentVolumeClaim, vgs []volumegroupv1.VolumeGroup) bool + func IsPVCPartOfVG(pvc *corev1.PersistentVolumeClaim, pvcList []corev1.PersistentVolumeClaim) bool + func ModifyVolumeGroup(logger logr.Logger, client client.Client, vg *volumegroupv1.VolumeGroup, ...) error + func RemoveFinalizerFromPVC(client runtimeclient.Client, logger logr.Logger, driver string, ...) error + func RemoveFinalizerFromVG(client runtimeclient.Client, logger logr.Logger, vg *volumegroupv1.VolumeGroup) error + func RemoveFinalizerFromVGC(client runtimeclient.Client, logger logr.Logger, ...) error + func RemovePVCFromVG(logger logr.Logger, client client.Client, pvc *corev1.PersistentVolumeClaim, ...) error + func RemovePVFromVGC(logger logr.Logger, client client.Client, pv *corev1.PersistentVolume, ...) error + func RemoveVolumeFromPvcListAndPvList(logger logr.Logger, client client.Client, driver string, ...) error + func RemoveVolumeFromVolumeGroup(logger logr.Logger, client client.Client, vgClient grpcClient.VolumeGroup, ...) error + func UpdateObject(client client.Client, updateObject client.Object) error + func UpdateObjectStatus(client client.Client, updateObject client.Object) error + func UpdateStaticVGC(client client.Client, vg *volumegroupv1.VolumeGroup, ...) error + func UpdateVolumeGroupContentStatus(client client.Client, logger logr.Logger, ...) error + func UpdateVolumeGroupSourceContent(client client.Client, instance *volumegroupv1.VolumeGroup, vgcName string, ...) error + func UpdateVolumeGroupStatus(client client.Client, vg *volumegroupv1.VolumeGroup, ...) error + func UpdateVolumeGroupStatusError(client client.Client, vg *volumegroupv1.VolumeGroup, logger logr.Logger, ...) error + func ValidatePrefixedParameters(param map[string]string) error