volume

Apr 8, 2016

Changes in this version

+ const ProvisionedVolumeName

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

+ func RoundUpSize(volumeSizeBytes int64, allocationUnitBytes int64) int64

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

+ 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 Attributes struct

+ Managed bool

+ ReadOnly bool

+ SupportsSELinux bool

type Builder

+ GetAttributes func() Attributes

+ type Detacher interface

+ Detach func() error

+ 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 NewCachedMetrics(provider MetricsProvider) MetricsProvider

+ func NewMetricsDu(path string) MetricsProvider

+ type ProvisionableVolumePlugin interface

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

+ type Provisioner interface

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

+ Provision func(*api.PersistentVolume) error

type VolumeHost

+ GetHostName func() string

type VolumeOptions

+ Capacity resource.Quantity

+ CloudTags *map[string]string

+ ClusterName string

+ PVName string

type VolumePluginMgr

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

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

Sep 25, 2015

Changes in this version

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

+ func NewPersistentVolumeRecyclerPodTemplate() *api.Pod

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

type Builder

+ IsReadOnly func() bool

+ 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

+ func (fv *FakeVolume) IsReadOnly() bool

type FakeVolumePlugin

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

type Recycler

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

type Spec

+ PersistentVolume *api.PersistentVolume

+ ReadOnly bool

+ Volume *api.Volume

+ type VolumeConfig struct

+ OtherAttributes map[string]string

+ RecyclerMinimumTimeout int

+ RecyclerPodTemplate *api.Pod

+ RecyclerTimeoutIncrement int

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 VolumePlugin

+ func ProbeVolumePlugins(config VolumeConfig) []VolumePlugin

type VolumePluginMgr

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

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

Jun 22, 2015

Changes in this version

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

+ type FakeRecycler struct

+ func (fr *FakeRecycler) GetPath() string

+ func (fr *FakeRecycler) Recycle() error

type FakeVolumePlugin

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

+ type RecyclableVolumePlugin interface

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

+ type Recycler interface

+ Recycle func() error

type VolumePluginMgr

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

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

Apr 29, 2015

Changes in this version

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

+ type Spec struct

+ Name string

+ PersistentVolumeSource api.PersistentVolumeSource

+ VolumeSource api.VolumeSource

+ func NewSpecFromPersistentVolume(pv *api.PersistentVolume) *Spec

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

+ type VolumeOptions struct

+ RootContext string

Mar 30, 2015

Changes in this version

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

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

type Builder

+ SetUpAt func(dir string) error

type Cleaner

+ TearDownAt func(dir string) error

+ type FakeVolume struct

+ Plugin *FakeVolumePlugin

+ PodUID types.UID

+ VolName string

+ 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 *api.Volume) bool

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

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

+ func (plugin *FakeVolumePlugin) Name() string

+ func (plugin *FakeVolumePlugin) NewBuilder(spec *api.Volume, podRef *api.ObjectReference) (Builder, error)

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

+ type PersistentVolumePlugin interface

+ GetAccessModes func() []api.AccessModeType

+ type Volume interface

+ GetPath func() string

+ 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 *api.Volume, podRef *api.ObjectReference) (Builder, error)

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

+ type VolumePlugin interface

+ CanSupport func(spec *api.Volume) bool

+ Init func(host VolumeHost)

+ Name func() string

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

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

+ type VolumePluginMgr struct

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

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

+ func (pm *VolumePluginMgr) FindPluginBySpec(spec *api.Volume) (VolumePlugin, error)

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

Nov 18, 2014

Changes in this version

+ type GitDir struct

+ Name string

+ PodID string

+ Revision string

+ RootDir string

+ Source string

+ func (g *GitDir) ExecCommand(command string, args []string, dir string) ([]byte, error)

+ func (g *GitDir) GetPath() string

+ func (g *GitDir) SetUp() error

+ func (g *GitDir) TearDown() error

Oct 17, 2014

Changes in this version

+ const MOUNT_MS_BIND

+ const MOUNT_MS_RDONLY

+ var ErrUnsupportedVolumeType = errors.New("unsupported volume type")

+ func GetCurrentVolumes(rootDirectory string) map[string]Cleaner

+ type Builder interface

+ SetUp func() error

+ func CreateVolumeBuilder(volume *api.Volume, podID string, rootDir string) (Builder, error)

+ type Cleaner interface

+ TearDown func() error

+ func CreateVolumeCleaner(kind string, name string, podID string, rootDir string) (Cleaner, error)

+ type DiskMounter struct

+ func (mounter *DiskMounter) Mount(source string, target string, fstype string, flags uintptr, data string) error

+ func (mounter *DiskMounter) RefCount(PD Interface) (string, int, error)

+ func (mounter *DiskMounter) RefCount(mount Interface) (string, int, error)

+ func (mounter *DiskMounter) Unmount(target string, flags int) error

+ type EmptyDir struct

+ Name string

+ PodID string

+ RootDir string

+ func (emptyDir *EmptyDir) GetPath() string

+ func (emptyDir *EmptyDir) SetUp() error

+ func (emptyDir *EmptyDir) TearDown() error

+ type GCEDiskUtil struct

+ func (util *GCEDiskUtil) AttachDisk(GCEPD *GCEPersistentDisk) error

+ func (util *GCEDiskUtil) DetachDisk(GCEPD *GCEPersistentDisk, devicePath string) error

+ type GCEPersistentDisk struct

+ FSType string

+ Name string

+ PDName string

+ Partition string

+ PodID string

+ ReadOnly bool

+ RootDir string

+ func (PD *GCEPersistentDisk) GetPath() string

+ func (PD *GCEPersistentDisk) SetUp() error

+ func (PD *GCEPersistentDisk) TearDown() error

+ type HostDir struct

+ Path string

+ func (hostVol *HostDir) GetPath() string

+ func (hostVol *HostDir) SetUp() error

+ type Interface interface

+ GetPath func() string