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
- type PersistentVolumeProvisionerController
- 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 (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()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewBinderClient ¶
func NewControllerClient ¶ added in v1.2.0
func NewPersistentVolumeOrderedIndex ¶
func NewPersistentVolumeOrderedIndex() *persistentVolumeOrderedIndex
func NewRecyclerClient ¶
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 (*PersistentVolumeProvisionerController) NewWrapperCleaner ¶ added in v1.2.0
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 (*PersistentVolumeRecycler) NewWrapperCleaner ¶
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