kubernetes/pkg/controller/nodelifecycle/node_lifecycle_controller_test.go

const testNodeMonitorGracePeriod …

const testNodeStartupGracePeriod …

const testNodeMonitorPeriod …

const testRateLimiterQPS …

const testLargeClusterThreshold …

const testUnhealthyThreshold …

func alwaysReady() bool { … }

func fakeGetPodsAssignedToNode(c *fake.Clientset) func(string) ([]*v1.Pod, error) { … }

type nodeLifecycleController …

func createNodeLease(nodeName string, renewTime metav1.MicroTime) *coordv1.Lease { … }

func (nc *nodeLifecycleController) syncLeaseStore(lease *coordv1.Lease) error { … }

func (nc *nodeLifecycleController) syncNodeStore(fakeNodeHandler *testutil.FakeNodeHandler) error { … }

func newNodeLifecycleControllerFromClient(
	ctx context.Context,
	kubeClient clientset.Interface,
	evictionLimiterQPS float32,
	secondaryEvictionLimiterQPS float32,
	largeClusterThreshold int32,
	unhealthyZoneThreshold float32,
	nodeMonitorGracePeriod time.Duration,
	nodeStartupGracePeriod time.Duration,
	nodeMonitorPeriod time.Duration,
) (*nodeLifecycleController, error) { … }

func TestMonitorNodeHealth(t *testing.T) { … }

func TestPodStatusChange(t *testing.T) { … }

func TestMonitorNodeHealthUpdateStatus(t *testing.T) { … }

func TestMonitorNodeHealthUpdateNodeAndPodStatusWithLease(t *testing.T) { … }

func TestMonitorNodeHealthMarkPodsNotReady(t *testing.T) { … }

// TestMonitorNodeHealthMarkPodsNotReadyWithWorkerSize tests the happy path of
// TestMonitorNodeHealthMarkPodsNotReady with a large number of nodes/pods and
// varying numbers of workers.
func TestMonitorNodeHealthMarkPodsNotReadyWithWorkerSize(t *testing.T) { … }

func TestMonitorNodeHealthMarkPodsNotReadyRetry(t *testing.T) { … }

// TestApplyNoExecuteTaints, ensures we just have a NoExecute taint applied to node.
// NodeController is just responsible for enqueuing the node to tainting queue from which taint manager picks up
// and evicts the pods on the node.
func TestApplyNoExecuteTaints(t *testing.T) { … }

// TestApplyNoExecuteTaintsToNodesEnqueueTwice ensures we taint every node with NoExecute even if enqueued twice
func TestApplyNoExecuteTaintsToNodesEnqueueTwice(t *testing.T) { … }

func TestSwapUnreachableNotReadyTaints(t *testing.T) { … }

func TestTaintsNodeByCondition(t *testing.T) { … }

func TestNodeEventGeneration(t *testing.T) { … }

func TestReconcileNodeLabels(t *testing.T) { … }

func TestTryUpdateNodeHealth(t *testing.T) { … }

func Test_isNodeExcludedFromDisruptionChecks(t *testing.T) { … }