package persistentvolume

import "k8s.io/kubernetes/pkg/controller/volume/persistentvolume"

Index ¶

• type ControllerParameters
• type PersistentVolumeController
• func NewController(p ControllerParameters) *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() (v1.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 (adc *PersistentVolumeController) GetSecretFunc() func(namespace, name string) (*v1.Secret, error)
• func (ctrl *PersistentVolumeController) GetWriter() io.Writer
• func (ctrl *PersistentVolumeController) NewWrapperMounter(volName string, spec vol.Spec, pod *v1.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 ControllerParameters ¶

type ControllerParameters struct {
	KubeClient                clientset.Interface
	SyncPeriod                time.Duration
	AlphaProvisioner          vol.ProvisionableVolumePlugin
	VolumePlugins             []vol.VolumePlugin
	Cloud                     cloudprovider.Interface
	ClusterName               string
	VolumeInformer            coreinformers.PersistentVolumeInformer
	ClaimInformer             coreinformers.PersistentVolumeClaimInformer
	ClassInformer             storageinformers.StorageClassInformer
	EventRecorder             record.EventRecorder
	EnableDynamicProvisioning bool
}

ControllerParameters contains arguments for creation of a new PersistentVolume controller.

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 NewController ¶

func NewController(p ControllerParameters) *PersistentVolumeController

NewController creates a new PersistentVolume controller

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() (v1.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) GetSecretFunc ¶

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

func (*PersistentVolumeController) GetWriter ¶

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

func (*PersistentVolumeController) NewWrapperMounter ¶

func (ctrl *PersistentVolumeController) NewWrapperMounter(volName string, spec vol.Spec, pod *v1.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

Source Files ¶

index.go pv_controller.go pv_controller_base.go volume_host.go

Directories ¶