kubernetes/pkg/controller/podgc/gc_controller.go

const gcCheckPeriod …

const quarantineTime …

type PodGCController …

func NewPodGC(ctx context.Context, kubeClient clientset.Interface, podInformer coreinformers.PodInformer,
	nodeInformer coreinformers.NodeInformer, terminatedPodThreshold int) *PodGCController { … }

// This function is only intended for integration tests
func NewPodGCInternal(ctx context.Context, kubeClient clientset.Interface, podInformer coreinformers.PodInformer,
	nodeInformer coreinformers.NodeInformer, terminatedPodThreshold int, gcCheckPeriod, quarantineTime time.Duration) *PodGCController { … }

func (gcc *PodGCController) Run(ctx context.Context) { … }

func (gcc *PodGCController) gc(ctx context.Context) { … }

func isPodTerminated(pod *v1.Pod) bool { … }

// isPodTerminating returns true if the pod is terminating.
func isPodTerminating(pod *v1.Pod) bool { … }

func (gcc *PodGCController) gcTerminating(ctx context.Context, pods []*v1.Pod) { … }

func (gcc *PodGCController) gcTerminated(ctx context.Context, pods []*v1.Pod) { … }

// gcOrphaned deletes pods that are bound to nodes that don't exist.
func (gcc *PodGCController) gcOrphaned(ctx context.Context, pods []*v1.Pod, nodes []*v1.Node) { … }

func (gcc *PodGCController) discoverDeletedNodes(ctx context.Context, existingNodeNames sets.String) (sets.String, bool) { … }

func (gcc *PodGCController) checkIfNodeExists(ctx context.Context, name string) (bool, error) { … }

// gcUnscheduledTerminating deletes pods that are terminating and haven't been scheduled to a particular node.
func (gcc *PodGCController) gcUnscheduledTerminating(ctx context.Context, pods []*v1.Pod) { … }

type byEvictionAndCreationTimestamp …

func (o byEvictionAndCreationTimestamp) Len() int      { … }

func (o byEvictionAndCreationTimestamp) Swap(i, j int) { … }

func (o byEvictionAndCreationTimestamp) Less(i, j int) bool { … }

func (gcc *PodGCController) markFailedAndDeletePod(ctx context.Context, pod *v1.Pod) error { … }

func (gcc *PodGCController) markFailedAndDeletePodWithCondition(ctx context.Context, pod *v1.Pod, condition *v1.PodCondition) error { … }