kubernetes/pkg/controller/volume/expand/expand_controller.go

const defaultWorkerCount …

type ExpandController …

type CSINameTranslator …

type expandController …

// NewExpandController expands the pvs
func NewExpandController(
	ctx context.Context,
	kubeClient clientset.Interface,
	pvcInformer coreinformers.PersistentVolumeClaimInformer,
	plugins []volume.VolumePlugin,
	translator CSINameTranslator,
	csiMigratedPluginManager csimigration.PluginManager) (ExpandController, error) { … }

func (expc *expandController) enqueuePVC(obj interface{ … }

func (expc *expandController) processNextWorkItem(ctx context.Context) bool { … }

// syncHandler performs actual expansion of volume. If an error is returned
// from this function - PVC will be requeued for resizing.
func (expc *expandController) syncHandler(ctx context.Context, key string) error { … }

func (expc *expandController) expand(logger klog.Logger, pvc *v1.PersistentVolumeClaim, pv *v1.PersistentVolume, resizerName string) error { … }

// TODO make concurrency configurable (workers argument). previously, nestedpendingoperations spawned unlimited goroutines
func (expc *expandController) Run(ctx context.Context) { … }

func (expc *expandController) runWorker(ctx context.Context) { … }

func (expc *expandController) getPersistentVolume(ctx context.Context, pvc *v1.PersistentVolumeClaim) (*v1.PersistentVolume, error) { … }

// isNodeExpandComplete returns true if  pvc.Status.Capacity >= pv.Spec.Capacity
func (expc *expandController) isNodeExpandComplete(logger klog.Logger, pvc *v1.PersistentVolumeClaim, pv *v1.PersistentVolume) bool { … }

// Implementing VolumeHost interface
func (expc *expandController) GetPluginDir(pluginName string) string { … }

func (expc *expandController) GetVolumeDevicePluginDir(pluginName string) string { … }

func (expc *expandController) GetPodsDir() string { … }

func (expc *expandController) GetPodVolumeDir(podUID types.UID, pluginName string, volumeName string) string { … }

func (expc *expandController) GetPodVolumeDeviceDir(podUID types.UID, pluginName string) string { … }

func (expc *expandController) GetPodPluginDir(podUID types.UID, pluginName string) string { … }

func (expc *expandController) GetKubeClient() clientset.Interface { … }

func (expc *expandController) NewWrapperMounter(volName string, spec volume.Spec, pod *v1.Pod) (volume.Mounter, error) { … }

func (expc *expandController) NewWrapperUnmounter(volName string, spec volume.Spec, podUID types.UID) (volume.Unmounter, error) { … }

func (expc *expandController) GetMounter(pluginName string) mount.Interface { … }

func (expc *expandController) GetExec(pluginName string) utilexec.Interface { … }

func (expc *expandController) GetHostName() string { … }

func (expc *expandController) GetHostIP() (net.IP, error) { … }

func (expc *expandController) GetNodeAllocatable() (v1.ResourceList, error) { … }

func (expc *expandController) GetSecretFunc() func(namespace, name string) (*v1.Secret, error) { … }

func (expc *expandController) GetConfigMapFunc() func(namespace, name string) (*v1.ConfigMap, error) { … }

func (expc *expandController) GetAttachedVolumesFromNodeStatus() (map[v1.UniqueVolumeName]string, error) { … }

func (expc *expandController) GetServiceAccountTokenFunc() func(_, _ string, _ *authenticationv1.TokenRequest) (*authenticationv1.TokenRequest, error) { … }

func (expc *expandController) DeleteServiceAccountTokenFunc() func(types.UID) { … }

func (expc *expandController) GetNodeLabels() (map[string]string, error) { … }

func (expc *expandController) GetNodeName() types.NodeName { … }

func (expc *expandController) GetEventRecorder() record.EventRecorder { … }

func (expc *expandController) GetSubpather() subpath.Interface { … }