Versions in this module Expand all Collapse all v0 v0.1.0 Feb 3, 2016 Changes in this version + func CalculateTimeoutForVolume(minimumTimeout, timeoutIncrement int, pv *api.PersistentVolume) int64 + func NewFakeVolumeHost(rootDir string, kubeClient client.Interface, plugins []VolumePlugin) *fakeVolumeHost + func NewPersistentVolumeRecyclerPodTemplate() *api.Pod + func RecycleVolumeByWatchingPodUntilCompletion(pod *api.Pod, kubeClient client.Interface) error + func RenameDirectory(oldPath, newName string) (string, error) + type Attributes struct + Managed bool + ReadOnly bool + SupportsOwnershipManagement bool + SupportsSELinux bool + type Builder interface + GetAttributes func() Attributes + SetUp func() error + SetUpAt func(dir string) error + type Cleaner interface + TearDown func() error + TearDownAt func(dir string) 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 FakeVolume struct + Plugin *FakeVolumePlugin + PodUID types.UID + VolName string + func (_ *FakeVolume) GetAttributes() Attributes + func (fv *FakeVolume) GetPath() string + 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) (Builder, error) + func (plugin *FakeVolumePlugin) NewCleaner(volName string, podUID types.UID) (Cleaner, error) + func (plugin *FakeVolumePlugin) NewDeleter(spec *Spec) (Deleter, 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 + func NewFakeRecycler(spec *Spec, host VolumeHost, config VolumeConfig) (Recycler, error) + type Spec struct + PersistentVolume *api.PersistentVolume + ReadOnly bool + Volume *api.Volume + func NewSpecFromPersistentVolume(pv *api.PersistentVolume, readOnly bool) *Spec + func NewSpecFromVolume(vs *api.Volume) *Spec + func (spec *Spec) Name() string + type Volume interface + GetPath func() string + type VolumeConfig struct + OtherAttributes map[string]string + RecyclerMinimumTimeout int + RecyclerPodTemplate *api.Pod + RecyclerTimeoutIncrement int + type VolumeHost interface + GetCloudProvider func() cloudprovider.Interface + GetHostName func() string + GetKubeClient func() client.Interface + GetMounter func() mount.Interface + GetPluginDir func(pluginName string) string + GetPodPluginDir func(podUID types.UID, pluginName string) string + GetPodVolumeDir func(podUID types.UID, pluginName string, volumeName string) string + GetWriter func() io.Writer + NewWrapperBuilder func(spec *Spec, pod *api.Pod, opts VolumeOptions) (Builder, error) + NewWrapperCleaner func(spec *Spec, podUID types.UID) (Cleaner, error) + type VolumeOptions struct + AccessModes []api.PersistentVolumeAccessMode + CapacityMB int + PersistentVolumeReclaimPolicy api.PersistentVolumeReclaimPolicy + 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) (Builder, error) + NewCleaner func(name string, podUID types.UID) (Cleaner, error) + func ProbeVolumePlugins(config VolumeConfig) []VolumePlugin + type VolumePluginMgr struct + func (pm *VolumePluginMgr) FindCreatablePluginBySpec(spec *Spec) (CreatableVolumePlugin, error) + func (pm *VolumePluginMgr) FindDeletablePluginBySpec(spec *Spec) (DeletableVolumePlugin, error) + 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
Go to main page