我正在使用 client-go（go 的 k8s 客戶端）以編程方式從集群中檢索和更新一些秘密。在這樣做時，我面臨著對我的代碼進行單元測試的需要，經過一番調查，我偶然發現了 client-go 的fake客戶端。但是，我還不能模擬錯誤。我已按照此問題的說明進行操作，但沒有成功。這里有我的業務邏輯：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錯誤。難道我做錯了什么？
1 回答
夢里花落0921
TA貢獻1772條經驗 獲得超6個贊
我終于找到了錯誤......它在反應堆函數的資源名稱中，我有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")
})
// ...
}
- 1 回答
- 0 關注
- 103 瀏覽
添加回答
舉報
0/150
提交
取消