kubernetes/pkg/kubelet/kubelet_node_status_test.go

const maxImageTagsForTest …

// generateTestingImageLists generate randomly generated image list and corresponding expectedImageList.
func generateTestingImageLists(count int, maxImages int) ([]kubecontainer.Image, []v1.ContainerImage) { … }

func makeExpectedImageList(imageList []kubecontainer.Image, maxImages int) []v1.ContainerImage { … }

func generateImageTags() []string { … }

func applyNodeStatusPatch(originalNode *v1.Node, patch []byte) (*v1.Node, error) { … }

func notImplemented(action core.Action) (bool, runtime.Object, error) { … }

func addNotImplatedReaction(kubeClient *fake.Clientset) { … }

type localCM …

func (lcm *localCM) GetNodeAllocatableReservation() v1.ResourceList { … }

func (lcm *localCM) GetCapacity(localStorageCapacityIsolation bool) v1.ResourceList { … }

type delegatingNodeLister …

func (l delegatingNodeLister) Get(name string) (*v1.Node, error) { … }

func (l delegatingNodeLister) List(selector labels.Selector) (ret []*v1.Node, err error) { … }

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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