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 {}