Documentation
¶
Index ¶
- Constants
- Variables
- 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 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 FilterPrefixedParameters(prefix string, param map[string]string) map[string]string
- func GenerateVGC(vgname string, instance *volumegroupv1.VolumeGroup, ...) *volumegroupv1.VolumeGroupContent
- func GetBoolField(object interface{}, fieldName string) bool
- func GetCurrentTime() *metav1.Time
- func GetMessageFromError(err error) string
- 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 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 GetSecretCred(vgClass *volumegroupv1.VolumeGroupClass) (string, string)
- func GetSecretDataFromClass(client client.Client, vgClass *volumegroupv1.VolumeGroupClass, ...) (map[string]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 GetVGList(logger logr.Logger, client client.Client, driver string) (volumegroupv1.VolumeGroupList, 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 IsContainOtherFinalizers(object runtimeclient.Object, logger logr.Logger) bool
- func IsPVCCanBeAddedToVG(logger logr.Logger, pvc *corev1.PersistentVolumeClaim, ...) error
- func IsPVCHasMatchingDriver(logger logr.Logger, client runtimeclient.Client, ...) (bool, error)
- func IsPVCInPVCList(pvc *corev1.PersistentVolumeClaim, pvcList []corev1.PersistentVolumeClaim) bool
- func IsPVCInStaticVG(logger logr.Logger, client runtimeclient.Client, ...) (bool, error)
- func IsPVCListEqual(x []corev1.PersistentVolumeClaim, y []corev1.PersistentVolumeClaim) bool
- func IsPVCMatchesVG(logger logr.Logger, pvc *corev1.PersistentVolumeClaim, ...) (bool, error)
- func IsPVCNeedToBeHandled(reqLogger logr.Logger, pvc *corev1.PersistentVolumeClaim, ...) (bool, error)
- func IsPVCPartAnyVG(pvc *corev1.PersistentVolumeClaim, vgs []volumegroupv1.VolumeGroup) bool
- 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 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 UpdateObject(client client.Client, updateObject client.Object) error
- func UpdateObjectStatus(client client.Client, updateObject client.Object) error
- func UpdatePvcAndPvList(logger logr.Logger, vg *volumegroupv1.VolumeGroup, client client.Client, ...) error
- func UpdateStaticVGC(client client.Client, vgcNamespace, vgcName string, ...) 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
- func ValidatePrefixedParameters(param map[string]string) error
Constants ¶
View Source
const ( VGNamePrefix = "volumegroup" VGFinalizer = vgGroupName VGAsPrefix = vgGroupName + "/" VgcFinalizer = VGAsPrefix + "vgc-protection" PrefixedVGSecretNameKey = VGAsPrefix + "secret-name" // name key for secret PrefixedVGSecretNamespaceKey = VGAsPrefix + "secret-namespace" // namespace key secret APIVersion = "csi.ibm.com/v1" )
Variables ¶
View Source
var ( PvcPredicate = predicate.Funcs{ CreateFunc: func(e event.CreateEvent) bool { return true }, DeleteFunc: func(e event.DeleteEvent) bool { return false }, UpdateFunc: func(e event.UpdateEvent) bool { return isLabelsChanged(e.ObjectOld, e.ObjectNew) || isPhaseChanged(e.ObjectOld, e.ObjectNew) }, GenericFunc: func(e event.GenericEvent) bool { return false }, } FinalizerPredicate = predicate.Funcs{ UpdateFunc: func(e event.UpdateEvent) bool { return !reflect.DeepEqual(e.ObjectNew.GetFinalizers(), e.ObjectOld.GetFinalizers()) }, } )
Functions ¶
func AddFinalizerToPVC ¶
func AddFinalizerToPVC(client runtimeclient.Client, logger logr.Logger, pvc *corev1.PersistentVolumeClaim) error
func AddFinalizerToVG ¶
func AddFinalizerToVG(client runtimeclient.Client, logger logr.Logger, vg *volumegroupv1.VolumeGroup) error
func AddFinalizerToVGC ¶
func AddFinalizerToVGC(client runtimeclient.Client, logger logr.Logger, vgc *volumegroupv1.VolumeGroupContent) error
func AddMatchingPVToMatchingVGC ¶
func AddMatchingPVToMatchingVGC(logger logr.Logger, client client.Client, pvc *corev1.PersistentVolumeClaim, vg *volumegroupv1.VolumeGroup) error
func AddPVCToVG ¶
func AddPVCToVG(logger logr.Logger, client client.Client, pvc *corev1.PersistentVolumeClaim, vg *volumegroupv1.VolumeGroup) error
func AddVolumeToPvcListAndPvList ¶
func AddVolumeToPvcListAndPvList(logger logr.Logger, client client.Client, pvc *corev1.PersistentVolumeClaim, vg *volumegroupv1.VolumeGroup) error
func CreateRequests ¶ added in v0.9.1
func CreateRequests(client runtimeclient.Client) handler.EventHandler
func CreateSuccessVGCEvent ¶ added in v0.9.1
func CreateSuccessVGCEvent(logger logr.Logger, client client.Client, vgc *volumegroupv1.VolumeGroupContent) error
func CreateVGC ¶ added in v0.9.1
func CreateVGC(client client.Client, logger logr.Logger, vgc *volumegroupv1.VolumeGroupContent) error
func DeletePVCsUnderVGC ¶ added in v0.9.1
func DeletePVCsUnderVGC(logger logr.Logger, client client.Client, vgc *volumegroupv1.VolumeGroupContent, driver string) error
func GenerateVGC ¶ added in v0.9.1
func GenerateVGC(vgname string, instance *volumegroupv1.VolumeGroup, vgClass *volumegroupv1.VolumeGroupClass, secretName string, secretNamespace string) *volumegroupv1.VolumeGroupContent
func GetBoolField ¶ added in v0.9.1
func GetCurrentTime ¶ added in v0.9.1
func GetMessageFromError ¶
func GetObjectField ¶ added in v0.9.1
func GetPVC ¶ added in v0.9.1
func GetPVC(logger logr.Logger, client runtimeclient.Client, name, namespace string) (*corev1.PersistentVolumeClaim, error)
func GetPVCClass ¶ added in v0.9.1
func GetPVCClass(claim *corev1.PersistentVolumeClaim) (string, error)
func GetPVCList ¶
func GetPVCList(logger logr.Logger, client runtimeclient.Client, driver string) (corev1.PersistentVolumeClaimList, error)
func GetPVFromPVC ¶
func GetPVFromPVC(logger logr.Logger, client client.Client, pvc *corev1.PersistentVolumeClaim) (*corev1.PersistentVolume, error)
func GetSecretCred ¶
func GetSecretCred(vgClass *volumegroupv1.VolumeGroupClass) (string, string)
func GetSecretDataFromClass ¶
func GetSecretDataFromClass(client client.Client, vgClass *volumegroupv1.VolumeGroupClass, logger logr.Logger) (map[string]string, error)
func GetStringField ¶ added in v0.9.1
func GetVG ¶ added in v0.9.1
func GetVG(client client.Client, logger logr.Logger, vgName string, vgNamespace string) (*volumegroupv1.VolumeGroup, error)
func GetVGC ¶ added in v0.9.1
func GetVGC(client client.Client, logger logr.Logger, vgcName string, vgcNamespace string) (*volumegroupv1.VolumeGroupContent, error)
func GetVGClass ¶ added in v0.9.1
func GetVGClass(client client.Client, logger logr.Logger, vgClassName string) (*volumegroupv1.VolumeGroupClass, error)
func GetVGList ¶
func GetVGList(logger logr.Logger, client client.Client, driver string) (volumegroupv1.VolumeGroupList, error)
func HandleErrorMessage ¶
func HandleErrorMessage(logger logr.Logger, client client.Client, vg *volumegroupv1.VolumeGroup, err error, reason string) error
func HandlePVCErrorMessage ¶
func HandleSuccessMessage ¶
func HandleSuccessMessage(logger logr.Logger, client client.Client, vg *volumegroupv1.VolumeGroup, message, reason string) error
func HandleVGCErrorMessage ¶
func HandleVGCErrorMessage(logger logr.Logger, client client.Client, vgc *volumegroupv1.VolumeGroupContent, err error, reason string) error
func IsContainOtherFinalizers ¶ added in v0.9.1
func IsContainOtherFinalizers(object runtimeclient.Object, logger logr.Logger) bool
func IsPVCCanBeAddedToVG ¶
func IsPVCCanBeAddedToVG(logger logr.Logger, pvc *corev1.PersistentVolumeClaim, vgs []volumegroupv1.VolumeGroup) error
func IsPVCHasMatchingDriver ¶
func IsPVCHasMatchingDriver(logger logr.Logger, client runtimeclient.Client, pvc *corev1.PersistentVolumeClaim, driver string) (bool, error)
func IsPVCInPVCList ¶ added in v0.9.1
func IsPVCInPVCList(pvc *corev1.PersistentVolumeClaim, pvcList []corev1.PersistentVolumeClaim) bool
func IsPVCInStaticVG ¶
func IsPVCInStaticVG(logger logr.Logger, client runtimeclient.Client, pvc *corev1.PersistentVolumeClaim) (bool, error)
func IsPVCListEqual ¶ added in v0.9.1
func IsPVCListEqual(x []corev1.PersistentVolumeClaim, y []corev1.PersistentVolumeClaim) bool
func IsPVCMatchesVG ¶
func IsPVCMatchesVG(logger logr.Logger, pvc *corev1.PersistentVolumeClaim, vg volumegroupv1.VolumeGroup) (bool, error)
func IsPVCNeedToBeHandled ¶ added in v0.9.1
func IsPVCNeedToBeHandled(reqLogger logr.Logger, pvc *corev1.PersistentVolumeClaim, client runtimeclient.Client, driverName string) (bool, error)
func IsPVCPartAnyVG ¶
func IsPVCPartAnyVG(pvc *corev1.PersistentVolumeClaim, vgs []volumegroupv1.VolumeGroup) bool
func IsVgExist ¶ added in v0.9.1
func IsVgExist(client client.Client, logger logr.Logger, vgc *volumegroupv1.VolumeGroupContent) (bool, error)
func ModifyVG ¶ added in v0.9.1
func ModifyVG(logger logr.Logger, client client.Client, vg *volumegroupv1.VolumeGroup, vgClient grpcClient.VolumeGroup) error
func ModifyVolumesInVG ¶ added in v0.9.1
func ModifyVolumesInVG(logger logr.Logger, client client.Client, vgClient grpcClient.VolumeGroup, matchingPvcs []corev1.PersistentVolumeClaim, vg volumegroupv1.VolumeGroup) error
func RemoveFinalizerFromPVC ¶
func RemoveFinalizerFromPVC(client runtimeclient.Client, logger logr.Logger, driver string, pvc *corev1.PersistentVolumeClaim) error
func RemoveFinalizerFromVG ¶
func RemoveFinalizerFromVG(client runtimeclient.Client, logger logr.Logger, vg *volumegroupv1.VolumeGroup) error
func RemoveFinalizerFromVGC ¶
func RemoveFinalizerFromVGC(client runtimeclient.Client, logger logr.Logger, vgc *volumegroupv1.VolumeGroupContent) error
func RemovePVCFromVG ¶
func RemovePVCFromVG(logger logr.Logger, client client.Client, pvc *corev1.PersistentVolumeClaim, vg *volumegroupv1.VolumeGroup) error
func RemovePVFromVGC ¶
func RemovePVFromVGC(logger logr.Logger, client client.Client, pv *corev1.PersistentVolume, vgc *volumegroupv1.VolumeGroupContent) error
func RemoveVolumeFromPvcListAndPvList ¶
func RemoveVolumeFromPvcListAndPvList(logger logr.Logger, client client.Client, driver string, pvc corev1.PersistentVolumeClaim, vg *volumegroupv1.VolumeGroup) error
func UpdateObjectStatus ¶
func UpdatePvcAndPvList ¶ added in v0.9.1
func UpdatePvcAndPvList(logger logr.Logger, vg *volumegroupv1.VolumeGroup, client client.Client, driver string, matchingPvcs []corev1.PersistentVolumeClaim) error
func UpdateStaticVGC ¶
func UpdateStaticVGC(client client.Client, vgcNamespace, vgcName string, vgClass *volumegroupv1.VolumeGroupClass, logger logr.Logger) error
func UpdateStaticVGCFromVG ¶ added in v0.9.1
func UpdateStaticVGCFromVG(client client.Client, vg *volumegroupv1.VolumeGroup, vgClass *volumegroupv1.VolumeGroupClass, logger logr.Logger) error
func UpdateThinVGC ¶ added in v0.9.1
func UpdateVGCByResponse ¶ added in v0.9.1
func UpdateVGCByResponse(client client.Client, vgc *volumegroupv1.VolumeGroupContent, resp *volumegroup.Response) error
func UpdateVGCStatus ¶ added in v0.9.1
func UpdateVGCStatus(client client.Client, logger logr.Logger, vgc *volumegroupv1.VolumeGroupContent, groupCreationTime *metav1.Time, ready bool) error
func UpdateVGCStatusError ¶ added in v0.9.1
func UpdateVGCStatusError(client client.Client, vgc *volumegroupv1.VolumeGroupContent, logger logr.Logger, message string) error
func UpdateVGSourceContent ¶ added in v0.9.1
func UpdateVGSourceContent(client client.Client, instance *volumegroupv1.VolumeGroup, vgcName string, logger logr.Logger) error
func UpdateVGStatus ¶ added in v0.9.1
func UpdateVGStatusError ¶ added in v0.9.1
func UpdateVGStatusError(client client.Client, vg *volumegroupv1.VolumeGroup, logger logr.Logger, message string) error
Types ¶
This section is empty.
Source Files
¶
Click to show internal directories.
Click to hide internal directories.