kubernetes/pkg/controller/volume/ephemeral/controller.go

type Controller …

type ephemeralController …

// NewController creates an ephemeral volume controller.
func NewController(
	ctx context.Context,
	kubeClient clientset.Interface,
	podInformer coreinformers.PodInformer,
	pvcInformer coreinformers.PersistentVolumeClaimInformer) (Controller, error) { … }

func (ec *ephemeralController) enqueuePod(obj interface{ … }

func (ec *ephemeralController) onPVCDelete(obj interface{ … }

func (ec *ephemeralController) Run(ctx context.Context, workers int) { … }

func (ec *ephemeralController) runWorker(ctx context.Context) { … }

func (ec *ephemeralController) processNextWorkItem(ctx context.Context) bool { … }

// syncHandler is invoked for each pod which might need to be processed.
// If an error is returned from this function, the pod will be requeued.
func (ec *ephemeralController) syncHandler(ctx context.Context, key string) error { … }

// handleEphemeralVolume is invoked for each volume of a pod.
func (ec *ephemeralController) handleVolume(ctx context.Context, pod *v1.Pod, vol v1.Volume) error { … }