1 package edgetocloud
2
3 import (
4 "testing"
5
6 dsapi "edge-infra.dev/pkg/edge/datasync/apis/v1alpha1"
7 "edge-infra.dev/pkg/k8s/testing/kmp"
8 "edge-infra.dev/test/f2"
9 "edge-infra.dev/test/f2/x/ktest"
10
11 "gotest.tools/v3/assert"
12 "gotest.tools/v3/assert/cmp"
13
14 "sigs.k8s.io/controller-runtime/pkg/client"
15 )
16
17 func TestE2CResources(t *testing.T) {
18 var k *ktest.K8s
19 feature := f2.NewFeature("Messaging Resources Check").
20 Setup("Initial setup", func(ctx f2.Context, t *testing.T) f2.Context {
21 k = ktest.FromContextT(ctx, t)
22 return ctx
23 }).
24 Test("Verify CouchDBPersistence in ready state", func(ctx f2.Context, t *testing.T) f2.Context {
25 persistenceResources := dsapi.CouchDBPersistenceList{}
26 err := k.Client.List(ctx, &persistenceResources, client.InNamespace(messagingNamespace))
27 assert.NilError(t, err)
28 assert.Check(t, cmp.Len(persistenceResources.Items, 1), "CouchDBPersistence be 1")
29
30 for _, persistence := range persistenceResources.Items {
31 persistence := persistence
32 k.WaitOn(t, k.Check(&persistence, kmp.IsReady()))
33 }
34 return ctx
35 }).
36 Feature()
37 f.Test(t, feature)
38 }
39
View as plain text