Skip to content

Commit e92ee83

Browse files
committed
add test for resilient single
1 parent 6081d4f commit e92ee83

File tree

1 file changed

+32
-0
lines changed

1 file changed

+32
-0
lines changed

tests/deployments_test.go

Lines changed: 32 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,14 @@ func TestDeploymentSingleRocksDB(t *testing.T) {
4242
deploymentSubTest(t, api.DeploymentModeSingle, api.StorageEngineRocksDB)
4343
}
4444

45+
func TestDeploymentResilientSingleMMFiles(t *testing.T) {
46+
deploymentSubTest(t, api.DeploymentModeResilientSingle, api.StorageEngineMMFiles)
47+
}
48+
49+
func TestDeploymentResilientSingleRocksDB(t *testing.T) {
50+
deploymentSubTest(t, api.DeploymentModeResilientSingle, api.StorageEngineRocksDB)
51+
}
52+
4553
func TestDeploymentClusterMMFiles(t *testing.T) {
4654
deploymentSubTest(t, api.DeploymentModeCluster, api.StorageEngineMMFiles)
4755
}
@@ -92,6 +100,30 @@ func deploymentSubTest(t *testing.T, mode api.DeploymentMode, engine api.Storage
92100
if err := waitUntilVersionUp(DBClient); err != nil {
93101
t.Fatalf("Single Server not running in time: %v", err)
94102
}
103+
} else if deployment.Spec.Mode == api.DeploymentModeResilientSingle {
104+
t.Log("##################################")
105+
if err := waitUntilVersionUp(DBClient); err != nil {
106+
t.Fatalf("Single Server not running in time: %v", err)
107+
}
108+
109+
//waitUntilResilientHealth
110+
111+
members := deployment.Status.Members
112+
//singels := members.Single
113+
114+
//run api/version for all servers
115+
116+
// TEST CODE BELOW
117+
agents := members.Agents
118+
if len(agents) == 0 {
119+
t.Fatal("This setup requires agents to work!")
120+
}
121+
122+
t.Logf("agents len: %v", len(agents))
123+
for _, server := range agents {
124+
t.Logf("Server: %v ", server)
125+
}
126+
t.Log("##################################")
95127
} else {
96128
t.Fatalf("DeploymentMode %v is not supported!", deployment.Spec.Mode)
97129
}

0 commit comments

Comments
 (0)