测试 kubernetes go client api 调用时通过 FieldSelector spec.nodeName 过滤 Pod 的方式

Question

作为在给定 k8s 节点中列出 pod 的编写逻辑的一部分，我有以下 api 调用：

func ListRunningPodsByNodeName(kubeClient kubernetes.Interface, nodeName string (*v1.PodList, error) {
  return kubeClient.
    CoreV1().
    Pods("").
    List(context.TODO(), metav1.ListOptions{
        FieldSelector: "spec.nodeName=" + nodeName,
    })
}

为了使用k8s提供的假客户端测试ListRunningPodsByNodeName，我想出了以下测试初始化​​：

func TestListRunningPodsByNodeName(t *testing.T) {

    // happy path
    kubeClient := fake.NewSimpleClientset(&v1.Pod{
    ObjectMeta: metav1.ObjectMeta{
        Name:        "pod1",
        Namespace:   "default",
        Annotations: map[string]string{},
    },
        Spec: v1.PodSpec{
            NodeName: "foo",
        },
    }, &v1.Pod{
            ObjectMeta: metav1.ObjectMeta{
                    Name:        "pod2",
                    Namespace:   "default",
                    Annotations: map[string]string{},
            },
            Spec: v1.PodSpec{
                NodeName: "bar",
            },
    })

    got, _ := ListRunningPodsByNodeName(kubeClient, "foo")

    for i, pod := range got.Items {
        fmt.Println(fmt.Sprintf("[%2d] %s", i, pod.GetName()))
    }

    t.Errorf("Error, expecting only one pod")
}

调试时，我得到了 pod1 和 pod2 Pod，尽管我正在过滤那些在 foo 节点中运行的 Pod。使用相同的方法通过某些元数据进行过滤就像一个魅力，但在通过 nodeName 过滤的情况下无法使其工作。 ¿ 有人知道为什么吗？我怀疑这可能是假客户端功能的限制，但还不能完全确定会打开一个问题

提前致谢

Answer 1

假的 k8s 客户端不支持按字段选择器过滤（请参阅this comment）。当使用假的 k8s 客户端进行单元测试时，最好假设 k8s 客户端将在现实世界中按预期工作（根据您的字段选择器查询返回正确的 pod）。在您的测试中，将 pod 提供给 您的应用程序 期望的假 k8s 客户端并测试您自己的逻辑，而不是同时测试 k8s 客户端的查询逻辑。

如果假客户端为您执行过滤绝对至关重要，您可以使用假客户端反应器将此自定义行为注入假客户端。这只是意味着更多样板代码。

可以通过添加处理特定类型操作的反应器，在操作中使用附加信息（在本例中为 ListAction#GetListRestrictions().Fields），将任何非泛型（如字段选择行为）注入测试，并自定义返回的数据

我根本没有测试过这个，但希望它能给你一些开始。

client := fake.NewSimpleClientset()
client.AddReactor("*", "MyResource", func(action testing.Action) (handled bool, ret runtime.Object, err error) {
    // Add custom filtering logic here
})