persistentvolume

Documentation

Index

• func NewBinderClient(c clientset.Interface) binderClient
• func NewControllerClient(c clientset.Interface) controllerClient
• func NewPersistentVolumeOrderedIndex() *persistentVolumeOrderedIndex
• func NewRecyclerClient(c clientset.Interface) recyclerClient
• type PersistentVolumeClaimBinder
  • func NewPersistentVolumeClaimBinder(kubeClient clientset.Interface, syncPeriod time.Duration) *PersistentVolumeClaimBinder
  • func (controller *PersistentVolumeClaimBinder) Run()
  • func (controller *PersistentVolumeClaimBinder) Stop()
• type PersistentVolumeProvisionerController
  • func NewPersistentVolumeProvisionerController(client controllerClient, syncPeriod time.Duration, clusterName string, ...) (*PersistentVolumeProvisionerController, error)
  • func (c *PersistentVolumeProvisionerController) GetCloudProvider() cloudprovider.Interface
  • func (c *PersistentVolumeProvisionerController) GetHostName() string
  • func (c *PersistentVolumeProvisionerController) GetKubeClient() clientset.Interface
  • func (c *PersistentVolumeProvisionerController) GetMounter() mount.Interface
  • func (c *PersistentVolumeProvisionerController) GetPluginDir(podUID string) string
  • func (c *PersistentVolumeProvisionerController) GetPodPluginDir(podUID types.UID, pluginName string) string
  • func (c *PersistentVolumeProvisionerController) GetPodVolumeDir(podUID types.UID, pluginName, volumeName string) string
  • func (c *PersistentVolumeProvisionerController) GetWriter() io.Writer
  • func (c *PersistentVolumeProvisionerController) NewWrapperBuilder(volName string, spec volume.Spec, pod *api.Pod, opts volume.VolumeOptions) (volume.Builder, error)
  • func (c *PersistentVolumeProvisionerController) NewWrapperCleaner(volName string, spec volume.Spec, podUID types.UID) (volume.Cleaner, error)
  • func (controller *PersistentVolumeProvisionerController) Run()
  • func (controller *PersistentVolumeProvisionerController) Stop()
• type PersistentVolumeRecycler
  • func NewPersistentVolumeRecycler(kubeClient clientset.Interface, syncPeriod time.Duration, maximumRetry int, ...) (*PersistentVolumeRecycler, error)
  • func (f *PersistentVolumeRecycler) GetCloudProvider() cloudprovider.Interface
  • func (f *PersistentVolumeRecycler) GetHostName() string
  • func (f *PersistentVolumeRecycler) GetKubeClient() clientset.Interface
  • func (f *PersistentVolumeRecycler) GetMounter() mount.Interface
  • func (f *PersistentVolumeRecycler) GetPluginDir(podUID string) string
  • func (f *PersistentVolumeRecycler) GetPodPluginDir(podUID types.UID, pluginName string) string
  • func (f *PersistentVolumeRecycler) GetPodVolumeDir(podUID types.UID, pluginName, volumeName string) string
  • func (f *PersistentVolumeRecycler) GetWriter() ioutil.Writer
  • func (f *PersistentVolumeRecycler) NewWrapperBuilder(volName string, spec volume.Spec, pod *api.Pod, opts volume.VolumeOptions) (volume.Builder, error)
  • func (f *PersistentVolumeRecycler) NewWrapperCleaner(volName string, spec volume.Spec, podUID types.UID) (volume.Cleaner, error)
  • func (recycler *PersistentVolumeRecycler) Run()
  • func (recycler *PersistentVolumeRecycler) Stop()

Functions

func NewBinderClient

func NewBinderClient(c clientset.Interface) binderClient

func NewControllerClient

func NewControllerClient(c clientset.Interface) controllerClient

func NewPersistentVolumeOrderedIndex

func NewPersistentVolumeOrderedIndex() *persistentVolumeOrderedIndex

func NewRecyclerClient

func NewRecyclerClient(c clientset.Interface) recyclerClient

Types

type PersistentVolumeClaimBinder

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

PersistentVolumeClaimBinder is a controller that synchronizes PersistentVolumeClaims.

func NewPersistentVolumeClaimBinder

func NewPersistentVolumeClaimBinder(kubeClient clientset.Interface, syncPeriod time.Duration) *PersistentVolumeClaimBinder

NewPersistentVolumeClaimBinder creates a new PersistentVolumeClaimBinder

func (*PersistentVolumeClaimBinder) Run

func (controller *PersistentVolumeClaimBinder) Run()

Run starts all of this binder's control loops

func (*PersistentVolumeClaimBinder) Stop

func (controller *PersistentVolumeClaimBinder) Stop()

Stop gracefully shuts down this binder

type PersistentVolumeProvisionerController

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

PersistentVolumeProvisionerController reconciles the state of all PersistentVolumes and PersistentVolumeClaims.

func NewPersistentVolumeProvisionerController

func NewPersistentVolumeProvisionerController(client controllerClient, syncPeriod time.Duration, clusterName string, plugins []volume.VolumePlugin, provisioner volume.ProvisionableVolumePlugin, cloud cloudprovider.Interface) (*PersistentVolumeProvisionerController, error)

NewPersistentVolumeProvisionerController creates a new PersistentVolumeProvisionerController

func (*PersistentVolumeProvisionerController) GetCloudProvider

func (c *PersistentVolumeProvisionerController) GetCloudProvider() cloudprovider.Interface

func (*PersistentVolumeProvisionerController) GetHostName

func (c *PersistentVolumeProvisionerController) GetHostName() string

func (*PersistentVolumeProvisionerController) GetKubeClient

func (c *PersistentVolumeProvisionerController) GetKubeClient() clientset.Interface

func (*PersistentVolumeProvisionerController) GetMounter

func (c *PersistentVolumeProvisionerController) GetMounter() mount.Interface

func (*PersistentVolumeProvisionerController) GetPluginDir

func (c *PersistentVolumeProvisionerController) GetPluginDir(podUID string) string

VolumeHost implementation PersistentVolumeRecycler is host to the volume plugins, but does not actually mount any volumes. Because no mounting is performed, most of the VolumeHost methods are not implemented.

func (*PersistentVolumeProvisionerController) GetPodPluginDir

func (c *PersistentVolumeProvisionerController) GetPodPluginDir(podUID types.UID, pluginName string) string

func (*PersistentVolumeProvisionerController) GetPodVolumeDir

func (c *PersistentVolumeProvisionerController) GetPodVolumeDir(podUID types.UID, pluginName, volumeName string) string

func (*PersistentVolumeProvisionerController) GetWriter

func (c *PersistentVolumeProvisionerController) GetWriter() io.Writer

func (*PersistentVolumeProvisionerController) NewWrapperBuilder

func (c *PersistentVolumeProvisionerController) NewWrapperBuilder(volName string, spec volume.Spec, pod *api.Pod, opts volume.VolumeOptions) (volume.Builder, error)

func (*PersistentVolumeProvisionerController) NewWrapperCleaner

func (c *PersistentVolumeProvisionerController) NewWrapperCleaner(volName string, spec volume.Spec, podUID types.UID) (volume.Cleaner, error)

func (*PersistentVolumeProvisionerController) Run

func (controller *PersistentVolumeProvisionerController) Run()

Run starts all of this controller's control loops

func (*PersistentVolumeProvisionerController) Stop

func (controller *PersistentVolumeProvisionerController) Stop()

Stop gracefully shuts down this controller

type PersistentVolumeRecycler

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

PersistentVolumeRecycler is a controller that watches for PersistentVolumes that are released from their claims. This controller will Recycle those volumes whose reclaim policy is set to PersistentVolumeReclaimRecycle and make them available again for a new claim.

func NewPersistentVolumeRecycler

func NewPersistentVolumeRecycler(kubeClient clientset.Interface, syncPeriod time.Duration, maximumRetry int, plugins []volume.VolumePlugin, cloud cloudprovider.Interface) (*PersistentVolumeRecycler, error)

NewPersistentVolumeRecycler creates a new PersistentVolumeRecycler

func (*PersistentVolumeRecycler) GetCloudProvider

func (f *PersistentVolumeRecycler) GetCloudProvider() cloudprovider.Interface

func (*PersistentVolumeRecycler) GetHostName

func (f *PersistentVolumeRecycler) GetHostName() string

func (*PersistentVolumeRecycler) GetKubeClient

func (f *PersistentVolumeRecycler) GetKubeClient() clientset.Interface

func (*PersistentVolumeRecycler) GetMounter

func (f *PersistentVolumeRecycler) GetMounter() mount.Interface

func (*PersistentVolumeRecycler) GetPluginDir

func (f *PersistentVolumeRecycler) GetPluginDir(podUID string) string

PersistentVolumeRecycler is host to the volume plugins, but does not actually mount any volumes. Because no mounting is performed, most of the VolumeHost methods are not implemented.

func (*PersistentVolumeRecycler) GetPodPluginDir

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

func (*PersistentVolumeRecycler) GetPodVolumeDir

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

func (*PersistentVolumeRecycler) GetWriter

func (f *PersistentVolumeRecycler) GetWriter() ioutil.Writer

func (*PersistentVolumeRecycler) NewWrapperBuilder

func (f *PersistentVolumeRecycler) NewWrapperBuilder(volName string, spec volume.Spec, pod *api.Pod, opts volume.VolumeOptions) (volume.Builder, error)

func (*PersistentVolumeRecycler) NewWrapperCleaner

func (f *PersistentVolumeRecycler) NewWrapperCleaner(volName string, spec volume.Spec, podUID types.UID) (volume.Cleaner, error)

func (*PersistentVolumeRecycler) Run

func (recycler *PersistentVolumeRecycler) Run()

Run starts this recycler's control loops

func (*PersistentVolumeRecycler) Stop

func (recycler *PersistentVolumeRecycler) Stop()

Stop gracefully shuts down this binder