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) GetCinderConfig() string
- 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) IsNoMountSupported() bool
- 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) GetCinderConfig() string
- 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) IsNoMountSupported() bool
- 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 v0.3.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 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 v0.3.0
type PersistentVolumeProvisionerController struct {
// contains filtered or unexported fields
}
PersistentVolumeProvisionerController reconciles the state of all PersistentVolumes and PersistentVolumeClaims.
func NewPersistentVolumeProvisionerController ¶ added in v0.3.0
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) GetCinderConfig ¶ added in v0.3.0
func (c *PersistentVolumeProvisionerController) GetCinderConfig() string
func (*PersistentVolumeProvisionerController) GetCloudProvider ¶ added in v0.3.0
func (c *PersistentVolumeProvisionerController) GetCloudProvider() cloudprovider.Interface
func (*PersistentVolumeProvisionerController) GetHostName ¶ added in v0.3.0
func (c *PersistentVolumeProvisionerController) GetHostName() string
func (*PersistentVolumeProvisionerController) GetKubeClient ¶ added in v0.3.0
func (c *PersistentVolumeProvisionerController) GetKubeClient() client.Interface
func (*PersistentVolumeProvisionerController) GetMounter ¶ added in v0.3.0
func (c *PersistentVolumeProvisionerController) GetMounter() mount.Interface
func (*PersistentVolumeProvisionerController) GetPluginDir ¶ added in v0.3.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 v0.3.0
func (c *PersistentVolumeProvisionerController) GetPodPluginDir(podUID types.UID, pluginName string) string
func (*PersistentVolumeProvisionerController) GetPodVolumeDir ¶ added in v0.3.0
func (c *PersistentVolumeProvisionerController) GetPodVolumeDir(podUID types.UID, pluginName, volumeName string) string
func (*PersistentVolumeProvisionerController) GetWriter ¶ added in v0.3.0
func (c *PersistentVolumeProvisionerController) GetWriter() io.Writer
func (*PersistentVolumeProvisionerController) IsNoMountSupported ¶ added in v0.3.0
func (c *PersistentVolumeProvisionerController) IsNoMountSupported() bool
func (*PersistentVolumeProvisionerController) NewWrapperBuilder ¶ added in v0.3.0
func (c *PersistentVolumeProvisionerController) NewWrapperBuilder(spec *volume.Spec, pod *api.Pod, opts volume.VolumeOptions) (volume.Builder, error)
func (*PersistentVolumeProvisionerController) NewWrapperCleaner ¶ added in v0.3.0
func (*PersistentVolumeProvisionerController) Run ¶ added in v0.3.0
func (controller *PersistentVolumeProvisionerController) Run()
Run starts all of this controller's control loops
func (*PersistentVolumeProvisionerController) Stop ¶ added in v0.3.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 client.Interface, syncPeriod time.Duration, plugins []volume.VolumePlugin, cloud cloudprovider.Interface) (*PersistentVolumeRecycler, error)
PersistentVolumeRecycler creates a new PersistentVolumeRecycler
func (*PersistentVolumeRecycler) GetCinderConfig ¶
func (f *PersistentVolumeRecycler) GetCinderConfig() string
func (*PersistentVolumeRecycler) GetCloudProvider ¶
func (f *PersistentVolumeRecycler) GetCloudProvider() cloudprovider.Interface
func (*PersistentVolumeRecycler) GetHostName ¶ added in v0.3.0
func (f *PersistentVolumeRecycler) GetHostName() string
func (*PersistentVolumeRecycler) GetKubeClient ¶
func (f *PersistentVolumeRecycler) GetKubeClient() client.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) IsNoMountSupported ¶
func (f *PersistentVolumeRecycler) IsNoMountSupported() bool
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