volumemanager

Jul 1, 2016

Changes in this version

+ type VolumeManager interface

+ GetMountedVolumesForPod func(podName types.UniquePodName) container.VolumeMap

+ GetVolumesForPodAndAppendSupplementalGroups func(pod *api.Pod) container.VolumeMap

+ GetVolumesInUse func() []api.UniqueVolumeName

+ MarkVolumesAsReportedInUse func(volumesReportedAsInUse []api.UniqueVolumeName)

+ Run func(stopCh <-chan struct{})

+ VolumeIsAttached func(volumeName api.UniqueVolumeName) bool

+ WaitForAttachAndMount func(pod *api.Pod) error

+ func NewVolumeManager(controllerAttachDetachEnabled bool, hostName string, podManager pod.Manager, ...) (VolumeManager, error)

Mar 17, 2015

Changes in this version

+ func NewFakeHost(rootDir string, kubeClient client.Interface, plugins []Plugin) *fakeHost

type Builder

+ SetUpAt func(dir string) error

type Cleaner

+ TearDownAt func(dir string) error

type FakeVolume

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

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

type Host

+ NewWrapperBuilder func(spec *api.Volume, podRef *api.ObjectReference) (Builder, error)

+ NewWrapperCleaner func(spec *api.Volume, podUID types.UID) (Cleaner, error)

Mar 3, 2015

Changes in this version

type FakeHost

+ KubeClient client.Interface

+ func (f *FakeHost) GetKubeClient() client.Interface

type Host

+ GetKubeClient func() client.Interface

Jan 21, 2015

Changes in this version

+ func EscapePluginName(in string) string

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

+ func UnescapePluginName(in string) string

+ type Builder interface

+ SetUp func() error

+ type Cleaner interface

+ TearDown func() error

+ type FakeHost struct

+ RootDir string

+ func (f *FakeHost) GetPluginDir(podUID string) string

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

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

+ type FakePlugin struct

+ Host Host

+ PluginName string

+ func (plugin *FakePlugin) CanSupport(spec *api.Volume) bool

+ func (plugin *FakePlugin) Init(host Host)

+ func (plugin *FakePlugin) Name() string

+ func (plugin *FakePlugin) NewBuilder(spec *api.Volume, podUID types.UID) (Builder, error)

+ func (plugin *FakePlugin) NewCleaner(volName string, podUID types.UID) (Cleaner, error)

+ type FakeVolume struct

+ Plugin *FakePlugin

+ PodUID types.UID

+ VolName string

+ func (fv *FakeVolume) GetPath() string

+ func (fv *FakeVolume) SetUp() error

+ func (fv *FakeVolume) TearDown() error

+ type Host interface

+ GetPluginDir func(pluginName string) string

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

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

+ type Interface interface

+ GetPath func() string

+ type Plugin interface

+ CanSupport func(spec *api.Volume) bool

+ Init func(host Host)

+ Name func() string

+ NewBuilder func(spec *api.Volume, podUID types.UID) (Builder, error)

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

+ type PluginMgr struct

+ func (pm *PluginMgr) FindPluginByName(name string) (Plugin, error)

+ func (pm *PluginMgr) FindPluginBySpec(spec *api.Volume) (Plugin, error)

+ func (pm *PluginMgr) InitPlugins(plugins []Plugin, host Host) error