persistentvolume

Documentation

Index

• type PersistentVolumeController
  • func NewPersistentVolumeController(kubeClient clientset.Interface, syncPeriod time.Duration, ...) *PersistentVolumeController
  • func (ctrl *PersistentVolumeController) GetCloudProvider() cloudprovider.Interface
  • func (ctrl *PersistentVolumeController) GetHostIP() (net.IP, error)
  • func (ctrl *PersistentVolumeController) GetHostName() string
  • func (ctrl *PersistentVolumeController) GetKubeClient() clientset.Interface
  • func (ctrl *PersistentVolumeController) GetMounter() mount.Interface
  • func (ctrl *PersistentVolumeController) GetNodeAllocatable() (api.ResourceList, error)
  • func (ctrl *PersistentVolumeController) GetPluginDir(pluginName string) string
  • func (ctrl *PersistentVolumeController) GetPodPluginDir(podUID types.UID, pluginName string) string
  • func (ctrl *PersistentVolumeController) GetPodVolumeDir(podUID types.UID, pluginName string, volumeName string) string
  • func (ctrl *PersistentVolumeController) GetRootContext() string
  • func (ctrl *PersistentVolumeController) GetWriter() io.Writer
  • func (ctrl *PersistentVolumeController) NewWrapperMounter(volName string, spec vol.Spec, pod *api.Pod, opts vol.VolumeOptions) (vol.Mounter, error)
  • func (ctrl *PersistentVolumeController) NewWrapperUnmounter(volName string, spec vol.Spec, podUID types.UID) (vol.Unmounter, error)
  • func (ctrl *PersistentVolumeController) Run(stopCh <-chan struct{})

Types

type PersistentVolumeController

type PersistentVolumeController struct {
	// contains filtered or unexported fields
}

PersistentVolumeController is a controller that synchronizes PersistentVolumeClaims and PersistentVolumes. It starts two cache.Controllers that watch PersistentVolume and PersistentVolumeClaim changes.

func NewPersistentVolumeController

func NewPersistentVolumeController(
	kubeClient clientset.Interface,
	syncPeriod time.Duration,
	alphaProvisioner vol.ProvisionableVolumePlugin,
	volumePlugins []vol.VolumePlugin,
	cloud cloudprovider.Interface,
	clusterName string,
	volumeSource, claimSource, classSource cache.ListerWatcher,
	eventRecorder record.EventRecorder,
	enableDynamicProvisioning bool,
) *PersistentVolumeController

NewPersistentVolumeController creates a new PersistentVolumeController

func (*PersistentVolumeController) GetCloudProvider

func (ctrl *PersistentVolumeController) GetCloudProvider() cloudprovider.Interface

func (*PersistentVolumeController) GetHostIP

func (ctrl *PersistentVolumeController) GetHostIP() (net.IP, error)

func (*PersistentVolumeController) GetHostName

func (ctrl *PersistentVolumeController) GetHostName() string

func (*PersistentVolumeController) GetKubeClient

func (ctrl *PersistentVolumeController) GetKubeClient() clientset.Interface

func (*PersistentVolumeController) GetMounter

func (ctrl *PersistentVolumeController) GetMounter() mount.Interface

func (*PersistentVolumeController) GetNodeAllocatable

func (ctrl *PersistentVolumeController) GetNodeAllocatable() (api.ResourceList, error)

func (*PersistentVolumeController) GetPluginDir

func (ctrl *PersistentVolumeController) GetPluginDir(pluginName string) string

func (*PersistentVolumeController) GetPodPluginDir

func (ctrl *PersistentVolumeController) GetPodPluginDir(podUID types.UID, pluginName string) string

func (*PersistentVolumeController) GetPodVolumeDir

func (ctrl *PersistentVolumeController) GetPodVolumeDir(podUID types.UID, pluginName string, volumeName string) string

func (*PersistentVolumeController) GetRootContext

func (ctrl *PersistentVolumeController) GetRootContext() string

func (*PersistentVolumeController) GetWriter

func (ctrl *PersistentVolumeController) GetWriter() io.Writer

func (*PersistentVolumeController) NewWrapperMounter

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

func (*PersistentVolumeController) NewWrapperUnmounter

func (ctrl *PersistentVolumeController) NewWrapperUnmounter(volName string, spec vol.Spec, podUID types.UID) (vol.Unmounter, error)

func (*PersistentVolumeController) Run

func (ctrl *PersistentVolumeController) Run(stopCh <-chan struct{})

Run starts all of this controller's control loops