Files
troubleshoot/pkg/analyze/cluster_pod_statuses_test.go
Dexter Yan f69ae77bc3 feat(analyzer): add detailed message for unhealthy pod (#1261)
* feat(analyzer): add detailed message for unhealthy pod
2023-07-17 08:01:40 +12:00

696 lines
23 KiB
Go

package analyzer
import (
"testing"
troubleshootv1beta2 "github.com/replicatedhq/troubleshoot/pkg/apis/troubleshoot/v1beta2"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
corev1 "k8s.io/api/core/v1"
)
func Test_ClusterPodStatuses(t *testing.T) {
tests := []struct {
name string
analyzer troubleshootv1beta2.ClusterPodStatuses
expectResult []*AnalyzeResult
files map[string][]byte
eventFiles map[string][]byte
}{
{
name: "pass_when_all_pods_are_healthy_in_specific_namespace",
analyzer: troubleshootv1beta2.ClusterPodStatuses{
AnalyzeMeta: troubleshootv1beta2.AnalyzeMeta{
CheckName: "pass_when_all_pods_are_healthy_in_specific_namespace",
},
Outcomes: []*troubleshootv1beta2.Outcome{
{
Warn: &troubleshootv1beta2.SingleOutcome{
When: "!= Healthy",
Message: "A Pod, {{ .Name }}, is unhealthy with a status of: {{ .Status.Reason }}. Restarting the pod may fix the issue.",
},
},
{
Pass: &troubleshootv1beta2.SingleOutcome{
When: "",
Message: "All Pods are OK.",
},
},
},
Namespaces: []string{"default"},
},
expectResult: []*AnalyzeResult{
{
IsPass: true,
IsWarn: false,
IsFail: false,
Title: "pass_when_all_pods_are_healthy_in_specific_namespace",
Message: "All Pods are OK.",
InvolvedObject: &corev1.ObjectReference{
APIVersion: "v1",
Kind: "Pod",
Namespace: "default",
Name: "random-pod-75b66db9b9-nqhp8",
},
},
},
files: map[string][]byte{
"cluster-resources/pods/default.json": []byte(defaultPods),
"cluster-resources/pods/other.json": []byte(otherPods),
"cluster-resources/pods/default-unhealthy.json": []byte(defaultPodsUnhealthy),
"cluster-resources/pods/other-unhealthy.json": []byte(otherPodsUnhealthy),
},
},
{
name: "pass_when_pods_are_healthy_in_all_namespaces",
analyzer: troubleshootv1beta2.ClusterPodStatuses{
AnalyzeMeta: troubleshootv1beta2.AnalyzeMeta{
CheckName: "pass_when_pods_are_healthy_in_all_namespaces",
},
Outcomes: []*troubleshootv1beta2.Outcome{
{
Warn: &troubleshootv1beta2.SingleOutcome{
When: "!= Healthy",
Message: "A Pod, {{ .Name }}, is unhealthy with a status of: {{ .Status.Reason }}. Restarting the pod may fix the issue.",
},
},
{
Pass: &troubleshootv1beta2.SingleOutcome{
When: "",
Message: "All Pods are OK.",
},
},
},
Namespaces: []string{},
},
expectResult: []*AnalyzeResult{
{
IsPass: true,
IsWarn: false,
IsFail: false,
Title: "pass_when_pods_are_healthy_in_all_namespaces",
Message: "All Pods are OK.",
InvolvedObject: &corev1.ObjectReference{
APIVersion: "v1",
Kind: "Pod",
Namespace: "default",
Name: "random-pod-75b66db9b9-nqhp8",
},
},
{
IsPass: true,
IsWarn: false,
IsFail: false,
Title: "pass_when_pods_are_healthy_in_all_namespaces",
Message: "All Pods are OK.",
InvolvedObject: &corev1.ObjectReference{
APIVersion: "v1",
Kind: "Pod",
Namespace: "other",
Name: "other-pod-75b66db9b9-nqhp8",
},
},
},
files: map[string][]byte{
"cluster-resources/pods/default.json": []byte(defaultPods),
"cluster-resources/pods/other.json": []byte(otherPods),
},
},
{
name: "fail_when_pods_are_unhealthy_in_specific_namespace",
analyzer: troubleshootv1beta2.ClusterPodStatuses{
AnalyzeMeta: troubleshootv1beta2.AnalyzeMeta{
CheckName: "fail_when_pods_are_unhealthy_in_specific_namespace",
},
Outcomes: []*troubleshootv1beta2.Outcome{
{
Fail: &troubleshootv1beta2.SingleOutcome{
When: "!= Healthy",
Message: "A pod is unhealthy",
},
},
{
Pass: &troubleshootv1beta2.SingleOutcome{
When: "",
Message: "All Pods are OK.",
},
},
},
Namespaces: []string{"default-unhealthy"},
},
expectResult: []*AnalyzeResult{
{
IsPass: false,
IsWarn: false,
IsFail: true,
Title: "fail_when_pods_are_unhealthy_in_specific_namespace",
Message: "A pod is unhealthy",
InvolvedObject: &corev1.ObjectReference{
APIVersion: "v1",
Kind: "Pod",
Namespace: "default-unhealthy",
Name: "random-pod-75b66db9b9-nqhp8",
},
},
},
files: map[string][]byte{
"cluster-resources/pods/default.json": []byte(defaultPods),
"cluster-resources/pods/other.json": []byte(otherPods),
"cluster-resources/pods/default-unhealthy.json": []byte(defaultPodsUnhealthy),
"cluster-resources/pods/other-unhealthy.json": []byte(otherPodsUnhealthy),
},
},
{
name: "fail_when_pods_are_unhealthy_in_specific_namespace_using_double_ne",
analyzer: troubleshootv1beta2.ClusterPodStatuses{
AnalyzeMeta: troubleshootv1beta2.AnalyzeMeta{
CheckName: "fail_when_pods_are_unhealthy_in_specific_namespace_using_double_ne",
},
Outcomes: []*troubleshootv1beta2.Outcome{
{
Fail: &troubleshootv1beta2.SingleOutcome{
When: "!== Healthy",
Message: "A pod is unhealthy",
},
},
{
Pass: &troubleshootv1beta2.SingleOutcome{
When: "",
Message: "All Pods are OK.",
},
},
},
Namespaces: []string{"default-unhealthy"},
},
expectResult: []*AnalyzeResult{
{
IsPass: false,
IsWarn: false,
IsFail: true,
Title: "fail_when_pods_are_unhealthy_in_specific_namespace_using_double_ne",
Message: "A pod is unhealthy",
InvolvedObject: &corev1.ObjectReference{
APIVersion: "v1",
Kind: "Pod",
Namespace: "default-unhealthy",
Name: "random-pod-75b66db9b9-nqhp8",
},
},
},
files: map[string][]byte{
"cluster-resources/pods/default.json": []byte(defaultPods),
"cluster-resources/pods/other.json": []byte(otherPods),
"cluster-resources/pods/default-unhealthy.json": []byte(defaultPodsUnhealthy),
"cluster-resources/pods/other-unhealthy.json": []byte(otherPodsUnhealthy),
},
},
{
name: "fail_when_pods_are_unhealthy_in_any_namespace",
analyzer: troubleshootv1beta2.ClusterPodStatuses{
AnalyzeMeta: troubleshootv1beta2.AnalyzeMeta{
CheckName: "fail_when_pods_are_unhealthy_in_all_namespaces",
},
Outcomes: []*troubleshootv1beta2.Outcome{
{
Fail: &troubleshootv1beta2.SingleOutcome{
When: "!= Healthy",
Message: "A pod is unhealthy",
},
},
{
Pass: &troubleshootv1beta2.SingleOutcome{
When: "",
Message: "All Pods are OK.",
},
},
},
Namespaces: []string{},
},
expectResult: []*AnalyzeResult{
{
IsPass: false,
IsWarn: false,
IsFail: true,
Title: "fail_when_pods_are_unhealthy_in_all_namespaces",
Message: "A pod is unhealthy",
InvolvedObject: &corev1.ObjectReference{
APIVersion: "v1",
Kind: "Pod",
Namespace: "default-unhealthy",
Name: "random-pod-75b66db9b9-nqhp8",
},
},
{
IsPass: false,
IsWarn: false,
IsFail: true,
Title: "fail_when_pods_are_unhealthy_in_all_namespaces",
Message: "A pod is unhealthy",
InvolvedObject: &corev1.ObjectReference{
APIVersion: "v1",
Kind: "Pod",
Namespace: "other-unhealthy",
Name: "other-pod-75b66db9b9-nqhp8",
},
},
{
IsPass: true,
IsWarn: false,
IsFail: false,
Title: "fail_when_pods_are_unhealthy_in_all_namespaces",
Message: "All Pods are OK.",
InvolvedObject: &corev1.ObjectReference{
APIVersion: "v1",
Kind: "Pod",
Namespace: "default",
Name: "random-pod-75b66db9b9-nqhp8",
},
},
{
IsPass: true,
IsWarn: false,
IsFail: false,
Title: "fail_when_pods_are_unhealthy_in_all_namespaces",
Message: "All Pods are OK.",
InvolvedObject: &corev1.ObjectReference{
APIVersion: "v1",
Kind: "Pod",
Namespace: "other",
Name: "other-pod-75b66db9b9-nqhp8",
},
},
},
files: map[string][]byte{
"cluster-resources/pods/default.json": []byte(defaultPods),
"cluster-resources/pods/other.json": []byte(otherPods),
"cluster-resources/pods/default-unhealthy.json": []byte(defaultPodsUnhealthy),
"cluster-resources/pods/other-unhealthy.json": []byte(otherPodsUnhealthy),
},
},
{
name: "warn_when_pods_are_unhealthy_in_specific_namespace_using_double_equals",
analyzer: troubleshootv1beta2.ClusterPodStatuses{
AnalyzeMeta: troubleshootv1beta2.AnalyzeMeta{
CheckName: "warn_when_pods_are_unhealthy_in_specific_namespace_using_double_equals",
},
Outcomes: []*troubleshootv1beta2.Outcome{
{
Warn: &troubleshootv1beta2.SingleOutcome{
When: "== CrashLoopBackOff",
Message: "A pod is unhealthy.",
},
},
{
Pass: &troubleshootv1beta2.SingleOutcome{
When: "",
Message: "All Pods are OK.",
},
},
},
Namespaces: []string{"default-unhealthy"},
},
expectResult: []*AnalyzeResult{
{
IsPass: false,
IsWarn: true,
IsFail: false,
Title: "warn_when_pods_are_unhealthy_in_specific_namespace_using_double_equals",
Message: "A pod is unhealthy.",
InvolvedObject: &corev1.ObjectReference{
APIVersion: "v1",
Kind: "Pod",
Namespace: "default-unhealthy",
Name: "random-pod-75b66db9b9-nqhp8",
},
},
},
files: map[string][]byte{
"cluster-resources/pods/default.json": []byte(defaultPods),
"cluster-resources/pods/other.json": []byte(otherPods),
"cluster-resources/pods/default-unhealthy.json": []byte(defaultPodsUnhealthy),
"cluster-resources/pods/other-unhealthy.json": []byte(otherPodsUnhealthy),
},
},
{
name: "warn_when_pods_are_unhealthy_in_specific_namespace_using_triple_equals",
analyzer: troubleshootv1beta2.ClusterPodStatuses{
AnalyzeMeta: troubleshootv1beta2.AnalyzeMeta{
CheckName: "warn_when_pods_are_unhealthy_in_specific_namespace_using_triple_equals",
},
Outcomes: []*troubleshootv1beta2.Outcome{
{
Warn: &troubleshootv1beta2.SingleOutcome{
When: "=== CrashLoopBackOff",
Message: "A pod is unhealthy.",
},
},
{
Pass: &troubleshootv1beta2.SingleOutcome{
When: "",
Message: "All Pods are OK.",
},
},
},
Namespaces: []string{"default-unhealthy"},
},
expectResult: []*AnalyzeResult{
{
IsPass: false,
IsWarn: true,
IsFail: false,
Title: "warn_when_pods_are_unhealthy_in_specific_namespace_using_triple_equals",
Message: "A pod is unhealthy.",
InvolvedObject: &corev1.ObjectReference{
APIVersion: "v1",
Kind: "Pod",
Namespace: "default-unhealthy",
Name: "random-pod-75b66db9b9-nqhp8",
},
},
},
files: map[string][]byte{
"cluster-resources/pods/default.json": []byte(defaultPods),
"cluster-resources/pods/other.json": []byte(otherPods),
"cluster-resources/pods/default-unhealthy.json": []byte(defaultPodsUnhealthy),
"cluster-resources/pods/other-unhealthy.json": []byte(otherPodsUnhealthy),
},
},
{
name: "show_message_of_pending_pods_with_wrong_node_affinity",
analyzer: troubleshootv1beta2.ClusterPodStatuses{
AnalyzeMeta: troubleshootv1beta2.AnalyzeMeta{
CheckName: "show_message_of_pending_pods_with_wrong_node_affinity",
},
Outcomes: []*troubleshootv1beta2.Outcome{
{
Warn: &troubleshootv1beta2.SingleOutcome{
When: "!= Healthy",
Message: "A Pod, {{ .Name }}, is unhealthy with a status of: {{ .Status.Reason }}. Message is: {{ .Status.Message }}",
},
},
},
Namespaces: []string{"message-pending-node-affinity"},
},
expectResult: []*AnalyzeResult{
{
IsPass: false,
IsWarn: true,
IsFail: false,
Title: "show_message_of_pending_pods_with_wrong_node_affinity",
Message: "A Pod, kotsadm-b6cb54c8f-zgzrn, is unhealthy with a status of: Pending. Message is: 0/1 nodes are available: 1 node(s) didn't match Pod's node affinity/selector. preemption: 0/1 nodes are available: 1 Preemption is not helpful for scheduling.",
InvolvedObject: &corev1.ObjectReference{
APIVersion: "v1",
Kind: "Pod",
Namespace: "message-pending-node-affinity",
Name: "kotsadm-b6cb54c8f-zgzrn",
},
},
},
files: map[string][]byte{
"cluster-resources/pods/message-pending-node-affinity.json": []byte(messagePendingNodeAffinity),
},
},
{
name: "show_message_of_container_creating_pod_with_failed_mount",
analyzer: troubleshootv1beta2.ClusterPodStatuses{
AnalyzeMeta: troubleshootv1beta2.AnalyzeMeta{
CheckName: "show_message_of_container_creating_pod_with_failed_mount",
},
Outcomes: []*troubleshootv1beta2.Outcome{
{
Warn: &troubleshootv1beta2.SingleOutcome{
When: "!= Healthy",
Message: "A Pod, {{ .Name }}, is unhealthy with a status of: {{ .Status.Reason }}. Message is: {{ .Status.Message }}",
},
},
},
Namespaces: []string{"message-container-creating-failed-mount"},
},
expectResult: []*AnalyzeResult{
{
IsPass: false,
IsWarn: true,
IsFail: false,
Title: "show_message_of_container_creating_pod_with_failed_mount",
Message: "A Pod, troubleshoot-copyfromhost-4m79m-psdjm, is unhealthy with a status of: ContainerCreating. Message is: MountVolume.SetUp failed for volume \"host\" : hostPath type check failed: /var/lib/collectd is not a directory. Unable to attach or mount volumes: unmounted volumes=[host], unattached volumes=[host kube-api-access-xddvj]: timed out waiting for the condition",
InvolvedObject: &corev1.ObjectReference{
APIVersion: "v1",
Kind: "Pod",
Namespace: "message-container-creating-failed-mount",
Name: "troubleshoot-copyfromhost-4m79m-psdjm",
},
},
},
files: map[string][]byte{
"cluster-resources/pods/message-container-creating-failed-mount.json": []byte(messageContainerCreatingFailedMount),
},
eventFiles: map[string][]byte{
"cluster-resources/events/message-container-creating-failed-mount.json": []byte(messageContainerCreatingFailedMountEvents),
},
},
{
name: "show_message_of_pod_crashloop_backoff",
analyzer: troubleshootv1beta2.ClusterPodStatuses{
AnalyzeMeta: troubleshootv1beta2.AnalyzeMeta{
CheckName: "show_message_of_pod_crashloop_backoff",
},
Outcomes: []*troubleshootv1beta2.Outcome{
{
Warn: &troubleshootv1beta2.SingleOutcome{
When: "!= Healthy",
Message: "A Pod, {{ .Name }}, is unhealthy with a status of: {{ .Status.Reason }}. Message is: {{ .Status.Message }}",
},
},
},
Namespaces: []string{"message-pod-crashloop-backoff"},
},
expectResult: []*AnalyzeResult{
{
IsPass: false,
IsWarn: true,
IsFail: false,
Title: "show_message_of_pod_crashloop_backoff",
Message: "A Pod, init-demo, is unhealthy with a status of: CrashLoopBackOff. Message is: failed to create shim task: OCI runtime create failed: runc create failed: unable to start container process: exec: \"wge\": executable file not found in $PATH: unknown",
InvolvedObject: &corev1.ObjectReference{
APIVersion: "v1",
Kind: "Pod",
Namespace: "message-pod-crashloop-backoff",
Name: "init-demo",
},
},
},
files: map[string][]byte{
"cluster-resources/pods/message-pod-crashloop-backoff.json": []byte(messagePodCrashLoopBackOff),
},
},
{
name: "show_message_of_init_pod_crashloop_backoff",
analyzer: troubleshootv1beta2.ClusterPodStatuses{
AnalyzeMeta: troubleshootv1beta2.AnalyzeMeta{
CheckName: "show_message_of_init_pod_crashloop_backoff",
},
Outcomes: []*troubleshootv1beta2.Outcome{
{
Warn: &troubleshootv1beta2.SingleOutcome{
When: "!= Healthy",
Message: "A Pod, {{ .Name }}, is unhealthy with a status of: {{ .Status.Reason }}. Message is: {{ .Status.Message }}",
},
},
},
Namespaces: []string{"message-pod-init-crashloop-backoff"},
},
expectResult: []*AnalyzeResult{
{
IsPass: false,
IsWarn: true,
IsFail: false,
Title: "show_message_of_init_pod_crashloop_backoff",
Message: "A Pod, init-demo2, is unhealthy with a status of: Init:RunContainerError. Message is: failed to create shim task: OCI runtime create failed: runc create failed: unable to start container process: exec: \"wge\": executable file not found in $PATH: unknown",
InvolvedObject: &corev1.ObjectReference{
APIVersion: "v1",
Kind: "Pod",
Namespace: "message-pod-init-crashloop-backoff",
Name: "init-demo2",
},
},
},
files: map[string][]byte{
"cluster-resources/pods/message-pod-init-crashloop-backoff.json": []byte(messagePodInitCrashLoopBackOff),
},
eventFiles: map[string][]byte{
"cluster-resources/events/message-pod-init-crashloop-backoff.json": []byte(messagePodInitCrashLoopBackOffEvents),
},
},
{
name: "show_message_of_pending_pod_resource",
analyzer: troubleshootv1beta2.ClusterPodStatuses{
AnalyzeMeta: troubleshootv1beta2.AnalyzeMeta{
CheckName: "show_message_of_pending_pod_resource",
},
Outcomes: []*troubleshootv1beta2.Outcome{
{
Warn: &troubleshootv1beta2.SingleOutcome{
When: "!= Healthy",
Message: "A Pod, {{ .Name }}, is unhealthy with a status of: {{ .Status.Reason }}. Message is: {{ .Status.Message }}",
},
},
},
Namespaces: []string{"message-pending-pod-resources"},
},
expectResult: []*AnalyzeResult{
{
IsPass: false,
IsWarn: true,
IsFail: false,
Title: "show_message_of_pending_pod_resource",
Message: "A Pod, pending-pod-resources-5fddcf7688-djjfc, is unhealthy with a status of: Pending. Message is: 0/1 nodes are available: 1 Insufficient nvidia.com/gpu. preemption: 0/1 nodes are available: 1 No preemption victims found for incoming pod.",
InvolvedObject: &corev1.ObjectReference{
APIVersion: "v1",
Kind: "Pod",
Namespace: "message-pending-pod-resources",
Name: "pending-pod-resources-5fddcf7688-djjfc",
},
},
},
files: map[string][]byte{
"cluster-resources/pods/message-pending-pod-resources.json": []byte(messagePendingPodResources),
},
},
{
name: "show_message_of_oom_killed_pod",
analyzer: troubleshootv1beta2.ClusterPodStatuses{
AnalyzeMeta: troubleshootv1beta2.AnalyzeMeta{
CheckName: "show_message_of_oom_killed_pod",
},
Outcomes: []*troubleshootv1beta2.Outcome{
{
Warn: &troubleshootv1beta2.SingleOutcome{
When: "!= Healthy",
Message: "A Pod, {{ .Name }}, is unhealthy with a status of: {{ .Status.Reason }}. Message is: {{ .Status.Message }}",
},
},
},
Namespaces: []string{"message-oomkill-pod"},
},
expectResult: []*AnalyzeResult{
{
IsPass: false,
IsWarn: true,
IsFail: false,
Title: "show_message_of_oom_killed_pod",
Message: "A Pod, oom-kill-job3-gbb89, is unhealthy with a status of: OOMKilled. Message is: ExitCode:137",
InvolvedObject: &corev1.ObjectReference{
APIVersion: "v1",
Kind: "Pod",
Namespace: "message-oomkill-pod",
Name: "oom-kill-job3-gbb89",
},
},
},
files: map[string][]byte{
"cluster-resources/pods/message-oomkill-pod.json": []byte(messageOOMKillPod),
},
},
{
name: "show_message_of_image_pull_fail",
analyzer: troubleshootv1beta2.ClusterPodStatuses{
AnalyzeMeta: troubleshootv1beta2.AnalyzeMeta{
CheckName: "show_message_of_image_pull_fail",
},
Outcomes: []*troubleshootv1beta2.Outcome{
{
Warn: &troubleshootv1beta2.SingleOutcome{
When: "!= Healthy",
Message: "A Pod, {{ .Name }}, is unhealthy with a status of: {{ .Status.Reason }}. Message is: {{ .Status.Message }}",
},
},
},
Namespaces: []string{"message-image-pull-fail"},
},
expectResult: []*AnalyzeResult{
{
IsPass: false,
IsWarn: true,
IsFail: false,
Title: "show_message_of_image_pull_fail",
Message: "A Pod, no-image-deployment-849c4c4958-rxqmt, is unhealthy with a status of: ErrImagePull. Message is: Failed to pull image \"noimage.com/no-such-image\": rpc error: code = Unknown desc = Error response from daemon: Get \"https://noimage.com/v2/\": x509: certificate is not valid for any names, but wanted to match noimage.com. Error: ErrImagePull. Error: ImagePullBackOff",
InvolvedObject: &corev1.ObjectReference{
APIVersion: "v1",
Kind: "Pod",
Namespace: "message-image-pull-fail",
Name: "no-image-deployment-849c4c4958-rxqmt",
},
},
},
files: map[string][]byte{
"cluster-resources/pods/message-image-pull-fail.json": []byte(messageImagePullFail),
},
eventFiles: map[string][]byte{
"cluster-resources/events/message-image-pull-fail.json": []byte(messageImagePullFailEvents),
},
},
{
name: "show_none_message_of_no_events_pod",
analyzer: troubleshootv1beta2.ClusterPodStatuses{
AnalyzeMeta: troubleshootv1beta2.AnalyzeMeta{
CheckName: "show_none_message_of_no_events_pod",
},
Outcomes: []*troubleshootv1beta2.Outcome{
{
Warn: &troubleshootv1beta2.SingleOutcome{
When: "!= Healthy",
Message: "A Pod, {{ .Name }}, is unhealthy with a status of: {{ .Status.Reason }}. Message is: {{ .Status.Message }}",
},
},
},
Namespaces: []string{"message-image-pull-fail"},
},
expectResult: []*AnalyzeResult{
{
IsPass: false,
IsWarn: true,
IsFail: false,
Title: "show_none_message_of_no_events_pod",
Message: "A Pod, no-image-deployment-849c4c4958-rxqmt, is unhealthy with a status of: ErrImagePull. Message is: None",
InvolvedObject: &corev1.ObjectReference{
APIVersion: "v1",
Kind: "Pod",
Namespace: "message-image-pull-fail",
Name: "no-image-deployment-849c4c4958-rxqmt",
},
},
},
files: map[string][]byte{
"cluster-resources/pods/message-image-pull-fail.json": []byte(messageImagePullFail),
},
},
}
for _, test := range tests {
t.Run(test.name, func(t *testing.T) {
req := require.New(t)
getFiles := func(n string, _ []string) (map[string][]byte, error) {
if file, ok := test.files[n]; ok {
return map[string][]byte{n: file}, nil
}
return test.files, nil
}
getEventFiles := func(n string, _ []string) (map[string][]byte, error) {
if file, ok := test.eventFiles[n]; ok {
return map[string][]byte{n: file}, nil
}
return test.files, nil
}
actual, err := clusterPodStatuses(&test.analyzer, getFiles, getEventFiles)
req.NoError(err)
req.Equal(len(test.expectResult), len(actual))
for _, a := range actual {
assert.Contains(t, test.expectResult, a)
}
})
}
}