persistentvolume

package
v1.2.0-beta.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 4, 2016 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewBinderClient 

func NewBinderClient(c clientset.Interface) binderClient

func NewControllerClient added in v1.2.0 

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 added in v1.2.0 

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

PersistentVolumeProvisionerController reconciles the state of all PersistentVolumes and PersistentVolumeClaims.

func NewPersistentVolumeProvisionerController added in v1.2.0 

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 added in v1.2.0 

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

func (*PersistentVolumeProvisionerController) GetHostName added in v1.2.0 

func (c *PersistentVolumeProvisionerController) GetHostName() string

func (*PersistentVolumeProvisionerController) GetKubeClient added in v1.2.0 

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

func (*PersistentVolumeProvisionerController) GetMounter added in v1.2.0 

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

func (*PersistentVolumeProvisionerController) GetPluginDir added in v1.2.0 

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 added in v1.2.0 

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

func (*PersistentVolumeProvisionerController) GetPodVolumeDir added in v1.2.0 

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

func (*PersistentVolumeProvisionerController) GetWriter added in v1.2.0 

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

func (*PersistentVolumeProvisionerController) NewWrapperBuilder added in v1.2.0 

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

func (*PersistentVolumeProvisionerController) NewWrapperCleaner added in v1.2.0 

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

func (*PersistentVolumeProvisionerController) Run added in v1.2.0 

func (controller *PersistentVolumeProvisionerController) Run()

Run starts all of this controller's control loops

func (*PersistentVolumeProvisionerController) Stop added in v1.2.0 

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 added in v1.2.0 

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.