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) GetRegionAndZone(nodeName string) (region, zone string, err error)
 - func (su *DriverStatsUtils) GetTotalCapacityFromPV(volumeID string) (resource.Quantity, error)
 
- type FakeStatsUtilsFuncStruct
 - type 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) GetRegionAndZone(nodeName string) (string, string, error)
 - func (m *FakeStatsUtilsFuncStructImpl) GetTotalCapacityFromPV(volumeID string) (resource.Quantity, error)
 
- type StatsUtils
 
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) GetBucketNameFromPV ¶
func (su *DriverStatsUtils) GetBucketNameFromPV(volumeID string) (string, error)
func (*DriverStatsUtils) GetBucketUsage ¶
func (su *DriverStatsUtils) GetBucketUsage(volumeID string) (int64, error)
func (*DriverStatsUtils) GetRegionAndZone ¶ added in v0.0.2
func (su *DriverStatsUtils) GetRegionAndZone(nodeName string) (region, zone string, err 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)
}
    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) GetBucketNameFromPV ¶
func (m *FakeStatsUtilsFuncStructImpl) GetBucketNameFromPV(volumeID string) (string, error)
func (*FakeStatsUtilsFuncStructImpl) GetBucketUsage ¶
func (m *FakeStatsUtilsFuncStructImpl) GetBucketUsage(volumeID string) (int64, error)
func (*FakeStatsUtilsFuncStructImpl) GetRegionAndZone ¶ added in v0.0.2
func (m *FakeStatsUtilsFuncStructImpl) GetRegionAndZone(nodeName string) (string, string, 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)
}
     Click to show internal directories. 
   Click to hide internal directories.