kubernetes/pkg/kubelet/nodeshutdown/nodeshutdown_manager.go

type Manager …

type Config …

type managerStub …

// Admit returns a fake Pod admission which always returns true
func (managerStub) Admit(attrs *lifecycle.PodAdmitAttributes) lifecycle.PodAdmitResult { … }

// Start is a no-op always returning nil for non linux platforms.
func (managerStub) Start() error { … }

// ShutdownStatus is a no-op always returning nil for non linux platforms.
func (managerStub) ShutdownStatus() error { … }

const nodeShutdownReason …

const nodeShutdownMessage …

type podManager …

func newPodManager(conf *Config) *podManager { … }

// killPods terminates pods by priority.
func (m *podManager) killPods(activePods []*v1.Pod) error { … }

func (m *podManager) periodRequested() time.Duration { … }

func migrateConfig(shutdownGracePeriodRequested, shutdownGracePeriodCriticalPods time.Duration) []kubeletconfig.ShutdownGracePeriodByPodPriority { … }

type podShutdownGroup …

func groupByPriority(shutdownGracePeriodByPodPriority []kubeletconfig.ShutdownGracePeriodByPodPriority, pods []*v1.Pod) []podShutdownGroup { … }