使用client-go伪客户端模拟错误

Question

我使用client-go (go的k8s客户端)以编程方式从集群中检索和更新一些秘密。在这样做的时候，我面临着对代码进行单元测试的需求，在进行了一些调查之后，我偶然发现了client -go的fake客户端。但是，我还不能模拟错误。我已经按照this issue的说明进行了操作，但是没有成功。

下面是我的业务逻辑：

func (g goClientRefresher) RefreshNamespace(ctx context.Context, namespace string) (err error, warnings bool) {
    client := g.kubeClient.CoreV1().Secrets(namespace)
    secrets, err := client.List(ctx, metav1.ListOptions{LabelSelector: "mutated-by=confidant"})
    if err != nil {
        return fmt.Errorf("unable to fetch secrets from cluster: %w", err), false
    }

    for _, secret := range secrets.Items {
        // business logic here
    }
    return nil, warnings
}

测试：

func TestWhenItsNotPossibleToFetchTheSecrets_ThenAnErrorIsReturned(t *testing.T) {
    kubeClient := getKubeClient()
    kubeClient.CoreV1().(*fakecorev1.FakeCoreV1).
        PrependReactor("list", "secret", func(action testingk8s.Action) (handled bool, ret runtime.Object, err error) {
            return true, &v1.SecretList{}, errors.New("error listing secrets")
        })
    r := getRefresher(kubeClient)


    err, warnings := r.RefreshNamespace(context.Background(), "target-ns")


    require.Error(t, err, "an error should have been raised")
}

然而，当我运行测试时，我得到了一个nil错误。我做错了什么吗？

Answer 1

我终于找到错误了..。它在反应堆函数的资源名称中，我有secret，它应该是复数secrets……:facepalm：。所以这是代码的正确版本：

func TestWhenItsNotPossibleToFetchTheSecrets_ThenAnErrorIsReturned(t *testing.T) {
    kubeClient := getKubeClient()
    kubeClient.CoreV1().(*fakecorev1.FakeCoreV1).
        PrependReactor("list", "secrets", func(action testingk8s.Action) (handled bool, ret runtime.Object, err error) {
            return true, &v1.SecretList{}, errors.New("error listing secrets")
        })
    // ...
}