volume

Feb 1, 2019

Changes in this version

+ type DeviceMountableVolumePlugin interface

+ GetDeviceMountRefs func(deviceMountPath string) ([]string, error)

+ NewDeviceMounter func() (DeviceMounter, error)

+ NewDeviceUnmounter func() (DeviceUnmounter, error)

+ type DeviceMounter interface

+ GetDeviceMountPath func(spec *Spec) (string, error)

+ MountDevice func(spec *Spec, devicePath string, deviceMountPath string) error

+ type DeviceUnmounter interface

+ UnmountDevice func(deviceMountPath string) error

+ type FSResizableVolumePlugin interface

+ ExpandFS func(spec *Spec, devicePath, deviceMountPath string, ...) error

type Spec

+ func (spec *Spec) IsKubeletExpandable() bool

+ func (spec *Spec) KubeletExpandablePluginName() string

type VolumeHost

+ DeleteServiceAccountTokenFunc func() func(podUID types.UID)

+ GetCSIClient func() csiclientset.Interface

type VolumePluginMgr

+ func (pm *VolumePluginMgr) FindDeviceMountablePluginByName(name string) (DeviceMountableVolumePlugin, error)

+ func (pm *VolumePluginMgr) FindDeviceMountablePluginBySpec(spec *Spec) (DeviceMountableVolumePlugin, error)

+ func (pm *VolumePluginMgr) FindFSResizablePluginByName(name string) (FSResizableVolumePlugin, error)

+ func (pm *VolumePluginMgr) FindFSResizablePluginBySpec(spec *Spec) (FSResizableVolumePlugin, error)

Dec 14, 2018

Changes in this version

type BlockVolumeMapper

+ MapDevice func(devicePath, globalMapPath, volumeMapPath, volumeMapName string, ...) error

+ type ProbeEvent struct

+ Op ProbeOperation

+ Plugin VolumePlugin

+ PluginName string

+ type ProbeOperation uint32

+ const ProbeAddOrUpdate

+ const ProbeRemove

type VolumeHost

+ GetEventRecorder func() record.EventRecorder

+ GetPodsDir func() string

+ GetServiceAccountTokenFunc func() ...

type VolumePluginMgr

+ func (pm *VolumePluginMgr) FindVolumePluginWithLimitsBySpec(spec *Spec) (VolumePluginWithAttachLimits, error)

+ func (pm *VolumePluginMgr) ListVolumePluginWithLimits() []VolumePluginWithAttachLimits

+ type VolumePluginWithAttachLimits interface

+ GetVolumeLimits func() (map[string]int64, error)

+ VolumeLimitKey func(spec *Spec) string

Dec 14, 2017

Changes in this version

+ type BlockVolume interface

+ GetGlobalMapPath func(spec *Spec) (string, error)

+ GetPodDeviceMapPath func() (string, string)

+ type BlockVolumeMapper interface

+ SetUpDevice func() (string, error)

+ type BlockVolumePlugin interface

+ ConstructBlockVolumeSpec func(podUID types.UID, volumeName, mountPath string) (*Spec, error)

+ NewBlockVolumeMapper func(spec *Spec, podRef *v1.Pod, opts VolumeOptions) (BlockVolumeMapper, error)

+ NewBlockVolumeUnmapper func(name string, podUID types.UID) (BlockVolumeUnmapper, error)

+ type BlockVolumeUnmapper interface

+ TearDownDevice func(mapPath string, devicePath string) error

type VolumeHost

+ GetNodeName func() types.NodeName

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

+ GetVolumeDevicePluginDir func(pluginName string) string

type VolumePluginMgr

+ func (pm *VolumePluginMgr) FindMapperPluginByName(name string) (BlockVolumePlugin, error)

+ func (pm *VolumePluginMgr) FindMapperPluginBySpec(spec *Spec) (BlockVolumePlugin, error)

Feb 4, 2018

Changes in this version

+ const VolumeParameterFSType

+ func ChooseZonesForVolume(zones sets.String, pvcName string, numZones uint32) sets.String

+ func GetWindowsPath(path string) string

+ func IsSameFSGroup(dir string, fsGroup int64) (bool, int, error)

+ type DynamicPluginProber interface

+ Init func() error

+ Probe func() (updated bool, probedPlugins []VolumePlugin, err error)

+ type ExpandableVolumePlugin interface

+ ExpandVolumeDevice func(spec *Spec, newSize resource.Quantity, oldSize resource.Quantity) (resource.Quantity, error)

+ RequiresFSResize func() bool

type VolumeHost

+ GetExec func(pluginName string) mount.Exec

type VolumeOptions

+ Containerized bool

+ MountOptions []string

type VolumePluginMgr

+ func (pm *VolumePluginMgr) FindExpandablePluginByName(name string) (ExpandableVolumePlugin, error)

+ func (pm *VolumePluginMgr) FindExpandablePluginBySpec(spec *Spec) (ExpandableVolumePlugin, error)

Jun 29, 2017

Changes in this version

+ const ErrCodeFsInfoFailed

+ const ErrCodeNoPathDefined

+ const ErrCodeNotSupported

+ func AccessModesContainedInAll(indexedModes []v1.PersistentVolumeAccessMode, ...) bool

+ func AccessModesContains(modes []v1.PersistentVolumeAccessMode, mode v1.PersistentVolumeAccessMode) bool

+ func IsDeletedVolumeInUse(err error) bool

+ func IsNotSupported(err error) bool

+ func JoinMountOptions(userOptions []string, systemOptions []string) []string

+ func MountOptionFromSpec(spec *Spec, options ...string) []string

+ func NewDeletedVolumeInUseError(message string) error

+ func UnmountViaEmptyDir(dir string, host VolumeHost, volName string, volSpec Spec, podUID types.UID) error

+ func ValidateRecyclerPodTemplate(pod *v1.Pod) error

+ func ValidateZone(zone string) error

+ func ZonesToSet(zonesString string) (sets.String, error)

type Attacher

+ VolumesAreAttached func(specs []*Spec, nodeName types.NodeName) (map[*Spec]bool, error)

+ type BulkVolumeVerifier interface

+ BulkVerifyVolumes func(volumesByNode map[types.NodeName][]*Spec) (map[types.NodeName]map[*Spec]bool, error)

type Metrics

+ Inodes *resource.Quantity

+ InodesFree *resource.Quantity

+ InodesUsed *resource.Quantity

+ Time metav1.Time

+ type MetricsError struct

+ Code int

+ Msg string

+ func NewFsInfoFailedError(err error) *MetricsError

+ func NewNoPathDefinedError() *MetricsError

+ func NewNotSupportedError() *MetricsError

+ func (e *MetricsError) Error() string

type Mounter

+ CanMount func() error

type RecyclableVolumePlugin

+ Recycle func(pvName string, spec *Spec, eventRecorder RecycleEventRecorder) error

type VolumeHost

+ GetConfigMapFunc func() func(namespace, name string) (*v1.ConfigMap, error)

+ GetNodeLabels func() (map[string]string, error)

+ GetSecretFunc func() func(namespace, name string) (*v1.Secret, error)

type VolumeOptions

+ PVC *v1.PersistentVolumeClaim

type VolumePlugin

+ SupportsBulkVolumeVerification func() bool

+ SupportsMountOption func() bool

type VolumePluginMgr

+ Host VolumeHost

Oct 29, 2016

Changes in this version

+ func GetPath(mounter Mounter) (string, error)

type AttachableVolumePlugin

+ GetDeviceMountRefs func(deviceMountPath string) ([]string, error)

+ type RecycleEventRecorder func(eventtype, message string)

type VolumeConfig

+ ProvisioningEnabled bool

type VolumeHost

+ GetNodeAllocatable func() (api.ResourceList, error)

type VolumeOptions

+ Parameters map[string]string

+ Selector *unversioned.LabelSelector

type VolumePlugin

+ ConstructVolumeSpec func(volumeName, mountPath string) (*Spec, error)

type VolumePluginMgr

+ func (pm *VolumePluginMgr) FindDeletablePluginByName(name string) (DeletableVolumePlugin, error)

+ func (pm *VolumePluginMgr) FindProvisionablePluginByName(name string) (ProvisionableVolumePlugin, error)

Jul 1, 2016

Changes in this version

+ const ProvisionedVolumeName

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

+ func ChooseZoneForVolume(zones sets.String, pvcName string) string

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

+ func NewPersistentVolumeRecyclerPodTemplate() *api.Pod

+ func RecycleVolumeByWatchingPodUntilCompletion(pvName string, pod *api.Pod, kubeClient clientset.Interface) error

+ func RoundUpSize(volumeSizeBytes int64, allocationUnitBytes int64) int64

+ func SetVolumeOwnership(mounter Mounter, fsGroup *int64) error

+ type AttachableVolumePlugin interface

+ NewAttacher func() (Attacher, error)

+ NewDetacher func() (Detacher, error)

+ type Attacher interface

+ Attach func(spec *Spec, hostName string) (string, error)

+ GetDeviceMountPath func(spec *Spec) (string, error)

+ MountDevice func(spec *Spec, devicePath string, deviceMountPath string) error

+ WaitForAttach func(spec *Spec, devicePath string, timeout time.Duration) (string, error)

+ type Attributes struct

+ Managed bool

+ ReadOnly bool

+ SupportsSELinux bool

+ type DeletableVolumePlugin interface

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

+ type Deleter interface

+ Delete func() error

+ type Detacher interface

+ Detach func(deviceName, hostName string) error

+ UnmountDevice func(deviceMountPath string) error

+ WaitForDetach func(devicePath string, timeout time.Duration) 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

+ func NewMetricsStatFS(path string) MetricsProvider

+ type Mounter interface

+ GetAttributes func() Attributes

+ SetUp func(fsGroup *int64) error

+ SetUpAt func(dir string, fsGroup *int64) error

+ type ProvisionableVolumePlugin interface

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

+ type Provisioner interface

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

type Spec

+ PersistentVolume *api.PersistentVolume

+ ReadOnly bool

+ Volume *api.Volume

+ type Unmounter interface

+ TearDown func() error

+ TearDownAt func(dir string) error

+ type VolumeConfig struct

+ OtherAttributes map[string]string

+ PVName string

+ RecyclerMinimumTimeout int

+ RecyclerPodTemplate *api.Pod

+ RecyclerTimeoutIncrement int

type VolumeHost

+ GetCloudProvider func() cloudprovider.Interface

+ GetHostIP func() (net.IP, error)

+ GetHostName func() string

+ GetMounter func() mount.Interface

+ GetRootContext func() string

+ GetWriter func() io.Writer

+ NewWrapperMounter func(volName string, spec Spec, pod *api.Pod, opts VolumeOptions) (Mounter, error)

+ NewWrapperUnmounter func(volName string, spec Spec, podUID types.UID) (Unmounter, error)

type VolumeOptions

+ AccessModes []api.PersistentVolumeAccessMode

+ Capacity resource.Quantity

+ CloudTags *map[string]string

+ ClusterName string

+ PVCName string

+ PVName string

+ PersistentVolumeReclaimPolicy api.PersistentVolumeReclaimPolicy

type VolumePlugin

+ GetPluginName func() string

+ GetVolumeName func(spec *Spec) (string, error)

+ NewMounter func(spec *Spec, podRef *api.Pod, opts VolumeOptions) (Mounter, error)

+ NewUnmounter func(name string, podUID types.UID) (Unmounter, error)

+ RequiresRemount func() bool

type VolumePluginMgr

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

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

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

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

Jul 11, 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 Spec struct

+ Name string

+ PersistentVolumeSource api.PersistentVolumeSource

+ VolumeSource api.VolumeSource

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

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

type VolumePluginMgr

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

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

Apr 13, 2015

Changes in this version

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

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

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

+ type Builder interface

+ SetUp func() error

+ SetUpAt func(dir string) error

+ type Cleaner interface

+ TearDown func() error

+ 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, opts VolumeOptions) (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, opts VolumeOptions) (Builder, error)

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

+ type VolumeOptions struct

+ RootContext string

+ type VolumePlugin interface

+ CanSupport func(spec *api.Volume) bool

+ Init func(host VolumeHost)

+ Name func() string

+ NewBuilder func(spec *api.Volume, podRef *api.ObjectReference, opts VolumeOptions) (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