util

Feb 7, 2018

Changes in this version

+ const FakeEntryBlock

+ const FakeEntryFile

+ const FakeEntryUnknown

+ type APIUtil interface

+ CreatePV func(pv *v1.PersistentVolume) (*v1.PersistentVolume, error)

+ DeletePV func(pvName string) error

+ func NewAPIUtil(client *kubernetes.Clientset) APIUtil

+ type FakeAPIUtil struct

+ func NewFakeAPIUtil(shouldFail bool, cache *cache.VolumeCache) *FakeAPIUtil

+ func (u *FakeAPIUtil) CreatePV(pv *v1.PersistentVolume) (*v1.PersistentVolume, error)

+ func (u *FakeAPIUtil) DeletePV(pvName string) error

+ func (u *FakeAPIUtil) GetAndResetCreatedPVs() map[string]*v1.PersistentVolume

+ func (u *FakeAPIUtil) GetAndResetDeletedPVs() map[string]*v1.PersistentVolume

+ type FakeDirEntry struct

+ Capacity int64

+ Hash uint32

+ Name string

+ VolumeType string

+ type FakeVolumeUtil struct

+ func NewFakeVolumeUtil(deleteShouldFail bool, dirFiles map[string][]*FakeDirEntry) *FakeVolumeUtil

+ func (u *FakeVolumeUtil) AddNewDirEntries(mountDir string, dirFiles map[string][]*FakeDirEntry)

+ func (u *FakeVolumeUtil) DeleteContents(fullPath string) error

+ func (u *FakeVolumeUtil) GetBlockCapacityByte(fullPath string) (int64, error)

+ func (u *FakeVolumeUtil) GetFsCapacityByte(fullPath string) (int64, error)

+ func (u *FakeVolumeUtil) IsBlock(fullPath string) (bool, error)

+ func (u *FakeVolumeUtil) IsDir(fullPath string) (bool, error)

+ func (u *FakeVolumeUtil) ReadDir(fullPath string) ([]string, error)

+ type VolumeUtil interface

+ DeleteContents func(fullPath string) error

+ GetBlockCapacityByte func(fullPath string) (int64, error)

+ GetFsCapacityByte func(fullPath string) (int64, error)

+ IsBlock func(fullPath string) (bool, error)

+ IsDir func(fullPath string) (bool, error)

+ ReadDir func(fullPath string) ([]string, error)

+ func NewVolumeUtil() VolumeUtil