kubernetes: github.com/CyrusBiotechnology/kubernetes/pkg/controller/persistentvolume Index | Files | Directories

package persistentvolume

import "github.com/CyrusBiotechnology/kubernetes/pkg/controller/persistentvolume"

Index

Package Files

persistentvolume_claim_binder_controller.go persistentvolume_provisioner_controller.go persistentvolume_recycler_controller.go types.go

func NewBinderClient Uses

func NewBinderClient(c clientset.Interface) binderClient

func NewControllerClient Uses

func NewControllerClient(c clientset.Interface) controllerClient

func NewPersistentVolumeOrderedIndex Uses

func NewPersistentVolumeOrderedIndex() *persistentVolumeOrderedIndex

func NewRecyclerClient Uses

func NewRecyclerClient(c clientset.Interface) recyclerClient

type PersistentVolumeClaimBinder Uses

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

PersistentVolumeClaimBinder is a controller that synchronizes PersistentVolumeClaims.

func NewPersistentVolumeClaimBinder Uses

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

NewPersistentVolumeClaimBinder creates a new PersistentVolumeClaimBinder

func (*PersistentVolumeClaimBinder) Run Uses

func (controller *PersistentVolumeClaimBinder) Run()

Run starts all of this binder's control loops

func (*PersistentVolumeClaimBinder) Stop Uses

func (controller *PersistentVolumeClaimBinder) Stop()

Stop gracefully shuts down this binder

type PersistentVolumeProvisionerController Uses

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

PersistentVolumeProvisionerController reconciles the state of all PersistentVolumes and PersistentVolumeClaims.

func NewPersistentVolumeProvisionerController Uses

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 Uses

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

func (*PersistentVolumeProvisionerController) GetHostName Uses

func (c *PersistentVolumeProvisionerController) GetHostName() string

func (*PersistentVolumeProvisionerController) GetKubeClient Uses

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

func (*PersistentVolumeProvisionerController) GetMounter Uses

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

func (*PersistentVolumeProvisionerController) GetPluginDir Uses

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 Uses

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

func (*PersistentVolumeProvisionerController) GetPodVolumeDir Uses

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

func (*PersistentVolumeProvisionerController) GetWriter Uses

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

func (*PersistentVolumeProvisionerController) NewWrapperMounter Uses

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

func (*PersistentVolumeProvisionerController) NewWrapperUnmounter Uses

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

func (*PersistentVolumeProvisionerController) Run Uses

func (controller *PersistentVolumeProvisionerController) Run()

Run starts all of this controller's control loops

func (*PersistentVolumeProvisionerController) Stop Uses

func (controller *PersistentVolumeProvisionerController) Stop()

Stop gracefully shuts down this controller

type PersistentVolumeRecycler Uses

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 Uses

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 Uses

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

func (*PersistentVolumeRecycler) GetHostName Uses

func (f *PersistentVolumeRecycler) GetHostName() string

func (*PersistentVolumeRecycler) GetKubeClient Uses

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

func (*PersistentVolumeRecycler) GetMounter Uses

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

func (*PersistentVolumeRecycler) GetPluginDir Uses

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 Uses

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

func (*PersistentVolumeRecycler) GetPodVolumeDir Uses

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

func (*PersistentVolumeRecycler) GetWriter Uses

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

func (*PersistentVolumeRecycler) NewWrapperMounter Uses

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

func (*PersistentVolumeRecycler) NewWrapperUnmounter Uses

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

func (*PersistentVolumeRecycler) Run Uses

func (recycler *PersistentVolumeRecycler) Run()

Run starts this recycler's control loops

func (*PersistentVolumeRecycler) Stop Uses

func (recycler *PersistentVolumeRecycler) Stop()

Stop gracefully shuts down this binder

Directories

PathSynopsis
options

Package persistentvolume imports 19 packages (graph). Updated 2017-04-15. Refresh now. Tools for package owners. This is a quick bug-fix fork (has fewer than three commits, and only during the week it was created).