Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

utils

package

Go to main page

Versions in this module

v0

v0.9.2

Feb 20, 2025

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