utils

Documentation

Index

• 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
  • 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
• type FakeStatsUtilsFuncStructImpl
  • 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

Functions

func CreateK8sClient

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

func GetPV

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

func GetPVC

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

func GetSecret

func GetSecret(secretName, secretNamespace string) (*v1.Secret, 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) 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)
}

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) 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)
}