volume

Mar 29, 2016

Changes in this version

+ const ProvisionedVolumeName

+ func GenerateVolumeName(clusterName, pvName string, maxLength int) string

type VolumeOptions

+ ClusterName string

+ PVName string

Mar 14, 2016

Changes in this version

+ type AttachableVolumePlugin interface

+ NewAttacher func(spec *Spec) (Attacher, error)

+ NewDetacher func(name string, podUID types.UID) (Detacher, error)

+ type Attacher interface

+ Attach func() error

+ type Detacher interface

+ Detach func() error

type FakeVolume

+ func (fv *FakeVolume) Attach() error

+ func (fv *FakeVolume) Detach() error

type FakeVolumePlugin

+ NewAttacherCallCount int

+ NewDetacherCallCount int

+ func (plugin *FakeVolumePlugin) NewAttacher(spec *Spec) (Attacher, error)

+ func (plugin *FakeVolumePlugin) NewDetacher(name string, podUID types.UID) (Detacher, error)

type MetricsProvider

+ func NewCachedMetrics(provider MetricsProvider) MetricsProvider

+ type MockVolume struct

+ func (_m *MockVolume) GetMetrics() (*Metrics, error)

+ func (_m *MockVolume) GetPath() string

type VolumePluginMgr

+ func (pm *VolumePluginMgr) FindAttachablePluginByName(name string) (AttachableVolumePlugin, error)

+ func (pm *VolumePluginMgr) FindAttachablePluginBySpec(spec *Spec) (AttachableVolumePlugin, error)

Feb 17, 2016

Changes in this version

+ func SetVolumeOwnership(builder Builder, fsGroup *int64) error

type FakeVolumePlugin

+ LastProvisionerOptions VolumeOptions

Feb 6, 2016

Changes in this version

+ func FindEmptyDirectoryUsageOnTmpfs() (*resource.Quantity, error)

+ type Attributes struct

+ Managed bool

+ ReadOnly bool

+ SupportsOwnershipManagement bool

+ SupportsSELinux bool

type Builder

+ GetAttributes func() Attributes

type FakeVolume

+ func (_ *FakeVolume) GetAttributes() Attributes

+ type Metrics struct

+ Available *resource.Quantity

+ Capacity *resource.Quantity

+ Used *resource.Quantity

+ type MetricsNil struct

+ func (*MetricsNil) GetMetrics() (*Metrics, error)

+ type MetricsProvider interface

+ GetMetrics func() (*Metrics, error)

+ func NewMetricsDu(path string) MetricsProvider

type VolumeHost

+ GetHostName func() string

Jan 18, 2016

Changes in this version

+ func RoundUpSize(volumeSizeBytes int64, allocationUnitBytes int64) int64

+ type FakeProvisioner struct

+ Host VolumeHost

+ Options VolumeOptions

+ func (fc *FakeProvisioner) NewPersistentVolumeTemplate() (*api.PersistentVolume, error)

+ func (fc *FakeProvisioner) Provision(pv *api.PersistentVolume) error

type FakeVolumePlugin

+ Config VolumeConfig

+ func (plugin *FakeVolumePlugin) NewProvisioner(options VolumeOptions) (Provisioner, error)

+ type ProvisionableVolumePlugin interface

+ NewProvisioner func(options VolumeOptions) (Provisioner, error)

+ type Provisioner interface

+ NewPersistentVolumeTemplate func() (*api.PersistentVolume, error)

+ Provision func(*api.PersistentVolume) error

type VolumeOptions

+ Capacity resource.Quantity

+ CloudTags *map[string]string

Nov 7, 2015

Changes in this version

type Builder

+ SupportsOwnershipManagement func() bool

+ SupportsSELinux func() bool

type FakeVolume

+ func (_ *FakeVolume) SupportsOwnershipManagement() bool

+ func (fv *FakeVolume) SupportsSELinux() bool

Oct 29, 2015

Changes in this version

+ func NewPersistentVolumeRecyclerPodTemplate() *api.Pod

+ func RecycleVolumeByWatchingPodUntilCompletion(pod *api.Pod, kubeClient client.Interface) error

+ type CreatableVolumePlugin interface

+ NewCreater func(options VolumeOptions) (Creater, error)

+ type Creater interface

+ Create func() (*api.PersistentVolume, error)

+ type DeletableVolumePlugin interface

+ NewDeleter func(spec *Spec) (Deleter, error)

+ type Deleter interface

+ Delete func() error

+ type FakeDeleter struct

+ func (fd *FakeDeleter) Delete() error

+ func (fd *FakeDeleter) GetPath() string

type FakeVolumePlugin

+ func (plugin *FakeVolumePlugin) NewDeleter(spec *Spec) (Deleter, error)

type Recycler

+ func NewFakeRecycler(spec *Spec, host VolumeHost, config VolumeConfig) (Recycler, error)

type VolumeConfig

+ RecyclerPodTemplate *api.Pod

type VolumeHost

+ GetCloudProvider func() cloudprovider.Interface

+ GetMounter func() mount.Interface

+ GetWriter func() io.Writer

type VolumeOptions

+ AccessModes []api.PersistentVolumeAccessMode

+ CapacityMB int

+ PersistentVolumeReclaimPolicy api.PersistentVolumeReclaimPolicy

type VolumePluginMgr

+ func (pm *VolumePluginMgr) FindCreatablePluginBySpec(spec *Spec) (CreatableVolumePlugin, error)

+ func (pm *VolumePluginMgr) FindDeletablePluginBySpec(spec *Spec) (DeletableVolumePlugin, error)

Sep 13, 2015

Changes in this version

+ func GetDefaultPersistentVolumeRecyclerPod() *api.Pod

type VolumeConfig

+ OtherAttributes map[string]string

+ RecyclerDefaultPod *api.Pod

+ RecyclerMinimumTimeout int

+ RecyclerTimeoutIncrement int

type VolumePlugin

+ func ProbeVolumePlugins(config VolumeConfig) []VolumePlugin

Aug 24, 2015

Changes in this version

+ func CalculateTimeoutForVolume(minimumTimeout, timeoutIncrement int64, pv *api.PersistentVolume) int64

+ func GetAccessModesAsString(modes []api.PersistentVolumeAccessMode) string

+ func InitScrubPod(filePath string) (*api.Pod, error)

+ func NewFakeVolumeHost(rootDir string, kubeClient client.Interface, plugins []VolumePlugin) *fakeVolumeHost

+ func RenameDirectory(oldPath, newName string) (string, error)

+ func ScrubPodVolumeAndWatchUntilCompletion(pod *api.Pod, kubeClient client.Interface) error

+ type Builder interface

+ IsReadOnly func() bool

+ SetUp func() error

+ SetUpAt func(dir string) error

+ type Cleaner interface

+ TearDown func() error

+ TearDownAt func(dir string) error

+ type FakeRecycler struct

+ func (fr *FakeRecycler) GetPath() string

+ func (fr *FakeRecycler) Recycle() error

+ type FakeVolume struct

+ Plugin *FakeVolumePlugin

+ PodUID types.UID

+ VolName string

+ func (fv *FakeVolume) GetPath() string

+ func (fv *FakeVolume) IsReadOnly() bool

+ func (fv *FakeVolume) SetUp() error

+ func (fv *FakeVolume) SetUpAt(dir string) error

+ func (fv *FakeVolume) TearDown() error

+ func (fv *FakeVolume) TearDownAt(dir string) error

+ type FakeVolumePlugin struct

+ Host VolumeHost

+ PluginName string

+ func (plugin *FakeVolumePlugin) CanSupport(spec *Spec) bool

+ func (plugin *FakeVolumePlugin) GetAccessModes() []api.PersistentVolumeAccessMode

+ func (plugin *FakeVolumePlugin) Init(host VolumeHost)

+ func (plugin *FakeVolumePlugin) Name() string

+ func (plugin *FakeVolumePlugin) NewBuilder(spec *Spec, pod *api.Pod, opts VolumeOptions, mounter mount.Interface) (Builder, error)

+ func (plugin *FakeVolumePlugin) NewCleaner(volName string, podUID types.UID, mounter mount.Interface) (Cleaner, error)

+ func (plugin *FakeVolumePlugin) NewRecycler(spec *Spec) (Recycler, error)

+ type PersistentVolumePlugin interface

+ GetAccessModes func() []api.PersistentVolumeAccessMode

+ type RecyclableVolumePlugin interface

+ NewRecycler func(spec *Spec) (Recycler, error)

+ type Recycler interface

+ Recycle func() error

+ type Spec struct

+ Name string

+ PersistentVolume *api.PersistentVolume

+ ReadOnly bool

+ Volume *api.Volume

+ func NewSpecFromPersistentVolume(pv *api.PersistentVolume, readOnly bool) *Spec

+ func NewSpecFromVolume(vs *api.Volume) *Spec

+ type Volume interface

+ GetPath func() string

+ type VolumeConfig struct

+ PersistentVolumeRecyclerDefaultScrubPod *api.Pod

+ PersistentVolumeRecyclerMinTimeoutHostPath int64

+ PersistentVolumeRecyclerMinTimeoutNfs int64

+ PersistentVolumeRecyclerTimeoutIncrementHostPath int64

+ PersistentVolumeRecyclerTimeoutIncrementNfs int64

+ func NewVolumeConfig() *VolumeConfig

+ type VolumeHost interface

+ GetKubeClient func() client.Interface

+ GetPluginDir func(pluginName string) string

+ GetPodPluginDir func(podUID types.UID, pluginName string) string

+ GetPodVolumeDir func(podUID types.UID, pluginName string, volumeName string) string

+ NewWrapperBuilder func(spec *Spec, pod *api.Pod, opts VolumeOptions, mounter mount.Interface) (Builder, error)

+ NewWrapperCleaner func(spec *Spec, podUID types.UID, mounter mount.Interface) (Cleaner, error)

+ type VolumeOptions struct

+ RootContext string

+ type VolumePlugin interface

+ CanSupport func(spec *Spec) bool

+ Init func(host VolumeHost)

+ Name func() string

+ NewBuilder func(spec *Spec, podRef *api.Pod, opts VolumeOptions, mounter mount.Interface) (Builder, error)

+ NewCleaner func(name string, podUID types.UID, mounter mount.Interface) (Cleaner, error)

+ type VolumePluginMgr struct

+ func (pm *VolumePluginMgr) FindPersistentPluginByName(name string) (PersistentVolumePlugin, error)

+ func (pm *VolumePluginMgr) FindPersistentPluginBySpec(spec *Spec) (PersistentVolumePlugin, error)

+ func (pm *VolumePluginMgr) FindPluginByName(name string) (VolumePlugin, error)

+ func (pm *VolumePluginMgr) FindPluginBySpec(spec *Spec) (VolumePlugin, error)

+ func (pm *VolumePluginMgr) FindRecyclablePluginBySpec(spec *Spec) (RecyclableVolumePlugin, error)

+ func (pm *VolumePluginMgr) InitPlugins(plugins []VolumePlugin, host VolumeHost) error