utils

Sep 9, 2025

Changes in this version

+ type ClusterNodeData struct

+ OS string

+ Region string

+ Zone string

type DriverStatsUtils

+ func (su *DriverStatsUtils) GetClusterNodeData(nodeName string) (*ClusterNodeData, error)

+ func (su *DriverStatsUtils) GetEndpoints() (string, string, error)

type FakeStatsUtilsFuncStruct

+ GetClusterNodeDataFn func(nodeName string) (*ClusterNodeData, error)

+ GetEndpointsFn func() (string, string, error)

type FakeStatsUtilsFuncStructImpl

+ func (m *FakeStatsUtilsFuncStructImpl) GetClusterNodeData(nodeName string) (*ClusterNodeData, error)

+ func (m *FakeStatsUtilsFuncStructImpl) GetEndpoints() (string, string, error)

type StatsUtils

+ GetClusterNodeData func(nodeName string) (*ClusterNodeData, error)

+ GetEndpoints func() (string, string, error)

Jun 19, 2025

Changes in this version

type DriverStatsUtils

+ func (su *DriverStatsUtils) GetPV(volumeID string) (*v1.PersistentVolume, error)

type FakeStatsUtilsFuncStruct

+ GetPVFn func(volumeID string) (*v1.PersistentVolume, error)

type FakeStatsUtilsFuncStructImpl

+ func (m *FakeStatsUtilsFuncStructImpl) GetPV(volumeID string) (*v1.PersistentVolume, error)

type StatsUtils

+ GetPV func(volumeID string) (*v1.PersistentVolume, error)

Jun 13, 2025

Changes in this version

type DriverStatsUtils

+ func (su *DriverStatsUtils) GetPVAttributes(volumeID string) (map[string]string, error)

+ func (su *DriverStatsUtils) GetPVC(pvcName, pvcNamespace string) (*v1.PersistentVolumeClaim, error)

+ func (su *DriverStatsUtils) GetSecret(secretName, secretNamespace string) (*v1.Secret, error)

type FakeStatsUtilsFuncStruct

+ GetPVAttributesFn func(volumeID string) (map[string]string, error)

+ GetPVCFn func(pvcName, pvcNamespace string) (*v1.PersistentVolumeClaim, error)

+ GetSecretFn func(secretName, secretNamespace string) (*v1.Secret, error)

type FakeStatsUtilsFuncStructImpl

+ func (m *FakeStatsUtilsFuncStructImpl) GetPVAttributes(volumeID string) (map[string]string, error)

+ func (m *FakeStatsUtilsFuncStructImpl) GetPVC(pvcName, pvcNamespace string) (*v1.PersistentVolumeClaim, error)

+ func (m *FakeStatsUtilsFuncStructImpl) GetSecret(secretName, secretNamespace string) (*v1.Secret, error)

type StatsUtils

+ GetPVAttributes func(volumeID string) (map[string]string, error)

+ GetPVC func(pvcName, pvcNamespace string) (*v1.PersistentVolumeClaim, error)

+ GetSecret func(secretName, secretNamespace string) (*v1.Secret, error)

May 29, 2025

Changes in this version

+ func GetPVAttributes(volumeID string) (map[string]string, error)

Mar 11, 2025

Changes in this version

type DriverStatsUtils

+ func (su *DriverStatsUtils) GetRegionAndZone(nodeName string) (region, zone string, err error)

type FakeStatsUtilsFuncStruct

+ GetRegionAndZoneFn func(nodeName string) (string, string, error)

type FakeStatsUtilsFuncStructImpl

+ func (m *FakeStatsUtilsFuncStructImpl) GetRegionAndZone(nodeName string) (string, string, error)

type StatsUtils

+ GetRegionAndZone func(nodeName string) (string, string, error)

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)