Documentation ¶
Index ¶
- func NewBinderClient(c client.Interface) binderClient
- func NewControllerClient(c client.Interface) controllerClient
- func NewPersistentVolumeOrderedIndex() *persistentVolumeOrderedIndex
- func NewRecyclerClient(c client.Interface) recyclerClient
- type PersistentVolumeClaimBinder
- type PersistentVolumeProvisionerController
- func (c *PersistentVolumeProvisionerController) GetCloudProvider() cloudprovider.Interface
- func (c *PersistentVolumeProvisionerController) GetHostName() string
- func (c *PersistentVolumeProvisionerController) GetKubeClient() client.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(spec *volume.Spec, pod *api.Pod, opts volume.VolumeOptions) (volume.Builder, error)
- func (c *PersistentVolumeProvisionerController) NewWrapperCleaner(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() client.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(spec *volume.Spec, pod *api.Pod, opts volume.VolumeOptions) (volume.Builder, error)
- func (f *PersistentVolumeRecycler) NewWrapperCleaner(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.1.1
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 client.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.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, 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() client.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(spec *volume.Spec, pod *api.Pod, opts volume.VolumeOptions) (volume.Builder, error)
func (*PersistentVolumeProvisionerController) NewWrapperCleaner ¶ added in v1.1.1
func (*PersistentVolumeProvisionerController) Run ¶ added in v1.1.1
func (controller *PersistentVolumeProvisionerController) Run()
Run starts all of this controller's control loops
func (*PersistentVolumeProvisionerController) Stop ¶ added in v1.1.1
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 client.Interface, syncPeriod time.Duration, plugins []volume.VolumePlugin, cloud cloudprovider.Interface) (*PersistentVolumeRecycler, error)
PersistentVolumeRecycler 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() client.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(spec *volume.Spec, pod *api.Pod, opts volume.VolumeOptions) (volume.Builder, error)
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