Function TestCollectNodeInfo

ami/kube/kube_collect_test.go:75–94

(t *testing.T)

}

func TestCollectNodeInfo(t *testing.T) {
	ami := initCollectKubeAMI(t)
	res, err := ami.CollectNodeInfo()
	assert.NoError(t, err)
	expected := map[string]interface{}{
		"node1": &specv1.NodeInfo{
			Hostname:         "hostname",
			Arch:             "arch",
			KernelVersion:    "kernel",
			OS:               "os",
			ContainerRuntime: "runtime",
			MachineID:        "machine",
			BootID:           "boot",
			SystemUUID:       "system",
			OSImage:          "image",
			Role:             "worker",
		},
	}
	assert.EqualValues(t, expected["node1"], res["node1"])
}

func TestGetContainerStatus(t *testing.T) {
	info := &v1.ContainerStatus{}