Versions in this module Expand all Collapse all v0 v0.0.0 Nov 25, 2024 Changes in this version + func CreateK8sClient() (*kubernetes.Clientset, error) + func GetPV(volumeID string) (*v1.PersistentVolume, error) + func GetPVC(pvcName, pvcNamespace string) (*v1.PersistentVolumeClaim, error) + func GetSecret(secretName, secretNamespace string) (*v1.Secret, error) + func ReplaceAndReturnCopy(req interface{}) (interface{}, error) + type DriverStatsUtils struct + func (su *DriverStatsUtils) BucketToDelete(volumeID string) (string, error) + func (su *DriverStatsUtils) CheckMount(targetPath string) error + func (su *DriverStatsUtils) FSInfo(path string) (int64, int64, int64, int64, int64, int64, error) + func (su *DriverStatsUtils) GetBucketNameFromPV(volumeID string) (string, error) + func (su *DriverStatsUtils) GetBucketUsage(volumeID string) (int64, error) + func (su *DriverStatsUtils) GetTotalCapacityFromPV(volumeID string) (resource.Quantity, error) + type FakeStatsUtilsFuncStruct struct + BucketToDeleteFn func(volumeID string) (string, error) + CheckMountFn func(targetPath string) error + FSInfoFn func(path string) (int64, int64, int64, int64, int64, int64, error) + GetBucketNameFromPVFn func(volumeID string) (string, error) + GetBucketUsageFn func(volumeID string) (int64, error) + GetTotalCapacityFromPVFn func(volumeID string) (resource.Quantity, error) + type FakeStatsUtilsFuncStructImpl struct + FuncStruct FakeStatsUtilsFuncStruct + func NewFakeStatsUtilsImpl(reqFn FakeStatsUtilsFuncStruct) *FakeStatsUtilsFuncStructImpl + func (m *FakeStatsUtilsFuncStructImpl) BucketToDelete(volumeID string) (string, error) + func (m *FakeStatsUtilsFuncStructImpl) CheckMount(targetPath string) error + func (m *FakeStatsUtilsFuncStructImpl) FSInfo(path string) (int64, int64, int64, int64, int64, int64, error) + func (m *FakeStatsUtilsFuncStructImpl) GetBucketNameFromPV(volumeID string) (string, error) + func (m *FakeStatsUtilsFuncStructImpl) GetBucketUsage(volumeID string) (int64, error) + func (m *FakeStatsUtilsFuncStructImpl) GetTotalCapacityFromPV(volumeID string) (resource.Quantity, error) + type StatsUtils interface + BucketToDelete func(volumeID string) (string, error) + CheckMount func(targetPath string) error + FSInfo func(path string) (int64, int64, int64, int64, int64, int64, error) + GetBucketNameFromPV func(volumeID string) (string, error) + GetBucketUsage func(volumeID string) (int64, error) + GetTotalCapacityFromPV func(volumeID string) (resource.Quantity, error)