utils

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 24, 2025 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateK8sClient 

func CreateK8sClient() (*kubernetes.Clientset, error)

func ReplaceAndReturnCopy 

func ReplaceAndReturnCopy(req interface{}) (interface{}, error)

Types

type DriverStatsUtils 

type DriverStatsUtils struct {
}

func (*DriverStatsUtils) BucketToDelete 

func (su *DriverStatsUtils) BucketToDelete(volumeID string) (string, error)

func (*DriverStatsUtils) CheckMount 

func (su *DriverStatsUtils) CheckMount(targetPath string) error

func (*DriverStatsUtils) FSInfo 

func (su *DriverStatsUtils) FSInfo(path string) (int64, int64, int64, int64, int64, int64, error)

func (*DriverStatsUtils) GetBucketNameFromPV 

func (su *DriverStatsUtils) GetBucketNameFromPV(volumeID string) (string, error)

func (*DriverStatsUtils) GetBucketUsage 

func (su *DriverStatsUtils) GetBucketUsage(volumeID string) (int64, error)

func (*DriverStatsUtils) GetPV added in v0.5.2 

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

func (*DriverStatsUtils) GetPVAttributes added in v0.5.1 

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

func (*DriverStatsUtils) GetPVC added in v0.5.1 

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

func (*DriverStatsUtils) GetRegionAndZone added in v0.0.2 

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

func (*DriverStatsUtils) GetSecret added in v0.5.1 

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

func (*DriverStatsUtils) GetTotalCapacityFromPV 

func (su *DriverStatsUtils) GetTotalCapacityFromPV(volumeID string) (resource.Quantity, error)

type FakeStatsUtilsFuncStruct 

type FakeStatsUtilsFuncStruct struct {
	FSInfoFn                 func(path string) (int64, int64, int64, int64, int64, int64, error)
	CheckMountFn             func(targetPath string) error
	BucketToDeleteFn         func(volumeID string) (string, error)
	GetTotalCapacityFromPVFn func(volumeID string) (resource.Quantity, error)
	GetBucketUsageFn         func(volumeID string) (int64, error)
	GetBucketNameFromPVFn    func(volumeID string) (string, error)
	GetRegionAndZoneFn       func(nodeName string) (string, string, error)
	GetPVAttributesFn        func(volumeID string) (map[string]string, error)
	GetPVCFn                 func(pvcName, pvcNamespace string) (*v1.PersistentVolumeClaim, error)
	GetSecretFn              func(secretName, secretNamespace string) (*v1.Secret, error)
	GetPVFn                  func(volumeID string) (*v1.PersistentVolume, error)
}

type FakeStatsUtilsFuncStructImpl 

type FakeStatsUtilsFuncStructImpl struct {
	DriverStatsUtils

	FuncStruct FakeStatsUtilsFuncStruct
}

func NewFakeStatsUtilsImpl 

func NewFakeStatsUtilsImpl(reqFn FakeStatsUtilsFuncStruct) *FakeStatsUtilsFuncStructImpl

func (*FakeStatsUtilsFuncStructImpl) BucketToDelete 

func (m *FakeStatsUtilsFuncStructImpl) BucketToDelete(volumeID string) (string, error)

func (*FakeStatsUtilsFuncStructImpl) CheckMount 

func (m *FakeStatsUtilsFuncStructImpl) CheckMount(targetPath string) error

func (*FakeStatsUtilsFuncStructImpl) FSInfo 

func (m *FakeStatsUtilsFuncStructImpl) FSInfo(path string) (int64, int64, int64, int64, int64, int64, error)

func (*FakeStatsUtilsFuncStructImpl) GetBucketNameFromPV 

func (m *FakeStatsUtilsFuncStructImpl) GetBucketNameFromPV(volumeID string) (string, error)

func (*FakeStatsUtilsFuncStructImpl) GetBucketUsage 

func (m *FakeStatsUtilsFuncStructImpl) GetBucketUsage(volumeID string) (int64, error)

func (*FakeStatsUtilsFuncStructImpl) GetPV added in v0.5.2 

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

func (*FakeStatsUtilsFuncStructImpl) GetPVAttributes added in v0.5.1 

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

func (*FakeStatsUtilsFuncStructImpl) GetPVC added in v0.5.1 

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

func (*FakeStatsUtilsFuncStructImpl) GetRegionAndZone added in v0.0.2 

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

func (*FakeStatsUtilsFuncStructImpl) GetSecret added in v0.5.1 

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

func (*FakeStatsUtilsFuncStructImpl) GetTotalCapacityFromPV 

func (m *FakeStatsUtilsFuncStructImpl) GetTotalCapacityFromPV(volumeID string) (resource.Quantity, error)

type StatsUtils 

type StatsUtils interface {
	BucketToDelete(volumeID string) (string, error)
	FSInfo(path string) (int64, int64, int64, int64, int64, int64, error)
	CheckMount(targetPath string) error
	GetTotalCapacityFromPV(volumeID string) (resource.Quantity, error)
	GetBucketUsage(volumeID string) (int64, error)
	GetBucketNameFromPV(volumeID string) (string, error)
	GetRegionAndZone(nodeName string) (string, string, error)
	GetPVAttributes(volumeID string) (map[string]string, error)
	GetPVC(pvcName, pvcNamespace string) (*v1.PersistentVolumeClaim, error)
	GetSecret(secretName, secretNamespace string) (*v1.Secret, error)
	GetPV(volumeID string) (*v1.PersistentVolume, error)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.