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 NewBinderClient(c clientset.Interface) binderClient
func NewControllerClient ¶ added in v1.1.1
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
type PersistentVolumeProvisionerController ¶ added in v1.1.1
type PersistentVolumeProvisionerController struct {
// contains filtered or unexported fields
}
PersistentVolumeProvisionerController reconciles the state of all PersistentVolumes and PersistentVolumeClaims.
func NewPersistentVolumeProvisionerController ¶ added in v1.1.1
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.1.1
func (c *PersistentVolumeProvisionerController) GetCloudProvider() cloudprovider.Interface
func (*PersistentVolumeProvisionerController) GetHostName ¶ added in v1.1.1
func (c *PersistentVolumeProvisionerController) GetHostName() string
func (*PersistentVolumeProvisionerController) GetKubeClient ¶ added in v1.1.1
func (c *PersistentVolumeProvisionerController) GetKubeClient() clientset.Interface
func (*PersistentVolumeProvisionerController) GetMounter ¶ added in v1.1.1
func (c *PersistentVolumeProvisionerController) GetMounter() mount.Interface
func (*PersistentVolumeProvisionerController) GetPluginDir ¶ added in v1.1.1
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.1.1
func (c *PersistentVolumeProvisionerController) GetPodPluginDir(podUID types.UID, pluginName string) string
func (*PersistentVolumeProvisionerController) GetPodVolumeDir ¶ added in v1.1.1
func (c *PersistentVolumeProvisionerController) GetPodVolumeDir(podUID types.UID, pluginName, volumeName string) string
func (*PersistentVolumeProvisionerController) GetWriter ¶ added in v1.1.1
func (c *PersistentVolumeProvisionerController) GetWriter() io.Writer
func (*PersistentVolumeProvisionerController) NewWrapperBuilder ¶ added in v1.1.1
func (c *PersistentVolumeProvisionerController) NewWrapperBuilder(volName string, spec volume.Spec, pod *api.Pod, opts volume.VolumeOptions) (volume.Builder, error)
func (*PersistentVolumeProvisionerController) NewWrapperCleaner ¶ added in v1.1.1
func (c *PersistentVolumeProvisionerController) NewWrapperCleaner(volName string, spec volume.Spec, podUID types.UID) (volume.Cleaner, error)
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 ¶ added in v1.0.7
func (f *PersistentVolumeRecycler) GetCloudProvider() cloudprovider.Interface
func (*PersistentVolumeRecycler) GetHostName ¶ added in v1.1.2
func (f *PersistentVolumeRecycler) GetHostName() string
func (*PersistentVolumeRecycler) GetKubeClient ¶
func (f *PersistentVolumeRecycler) GetKubeClient() clientset.Interface
func (*PersistentVolumeRecycler) GetMounter ¶ added in v1.0.7
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 ¶ added in v1.0.7
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)