Bitnami/charts
2
0
Fork 0
mirror of https://github.com/bitnami/charts.git synced 2026-08-10 14:15:55 +08:00
Code Issues Packages Projects Releases Wiki Activity

[bitnami/nats] Improve Ginkgo tests to make tests more stable (#23999)

Browse Source 
Signed-off-by: Jota Martos <jotamartos@vmware.com>
This commit is contained in:
Juan José Martos
2024-03-01 15:22:42 +01:00
committed by GitHub
parent ed87515fc4
commit 35b5a98b53
1 changed files with 21 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
.vib/nats/ginkgo/nats_test.go
+21 -1
View File
@@ -68,8 +68,18 @@ var _ = Describe("NATS", Ordered, func() {
return c.BatchV1().Jobs(namespace).Get(ctx, createDBJobName, getOpts)
}, timeout, PollingInterval).Should(WithTransform(getSucceededJobs, Equal(int32(1))))
By("puting a value into a key")
putJobName := fmt.Sprintf("%s-putbc-%s",
stsName, jobSuffix)
err = createJob(ctx, c, putJobName, port, "put", bucketName, "testKey", "testValue")
Expect(err).NotTo(HaveOccurred())
Eventually(func() (*batchv1.Job, error) {
return c.BatchV1().Jobs(namespace).Get(ctx, putJobName, getOpts)
}, timeout, PollingInterval).Should(WithTransform(getSucceededJobs, Equal(int32(1))))
// Give the application some time to sync the data
time.Sleep(5*time.Second)
time.Sleep(10*time.Second)
By("scaling down to 0 replicas")
ss, err = utils.StsScale(ctx, c, ss, 0)
@@ -87,6 +97,16 @@ var _ = Describe("NATS", Ordered, func() {
return c.AppsV1().StatefulSets(namespace).Get(ctx, stsName, getOpts)
}, timeout, PollingInterval).Should(WithTransform(getAvailableReplicas, Equal(origReplicas)))
By("getting a value for a key")
getJobName := fmt.Sprintf("%s-getbc-%s",
stsName, jobSuffix)
err = createJob(ctx, c, getJobName, port, "get", bucketName, "testKey")
Expect(err).NotTo(HaveOccurred())
Eventually(func() (*batchv1.Job, error) {
return c.BatchV1().Jobs(namespace).Get(ctx, getJobName, getOpts)
}, timeout, PollingInterval).Should(WithTransform(getSucceededJobs, Equal(int32(1))))
By("creating a job to get the test bucket")
deleteDBJobName := fmt.Sprintf("%s-delbc-%s",
stsName, jobSuffix)