run the full coordinator test suite
parent
97037dbde7
commit
8fdd6b750a
|
@ -5,7 +5,6 @@ import (
|
|||
"configuration"
|
||||
"datastore"
|
||||
"encoding/json"
|
||||
"flag"
|
||||
"fmt"
|
||||
"io/ioutil"
|
||||
. "launchpad.net/gocheck"
|
||||
|
@ -20,8 +19,6 @@ import (
|
|||
"time"
|
||||
)
|
||||
|
||||
var noSkipReplicationTests = flag.Bool("no-skip-replication", false, "Do not skip replication tests")
|
||||
|
||||
// Hook up gocheck into the gotest runner.
|
||||
func Test(t *testing.T) {
|
||||
TestingT(t)
|
||||
|
@ -176,10 +173,6 @@ func (self *CoordinatorSuite) TestCanRecover(c *C) {
|
|||
}
|
||||
|
||||
func (self *CoordinatorSuite) TestCanCreateCoordinatorsAndReplicate(c *C) {
|
||||
if !*noSkipReplicationTests {
|
||||
c.Skip("Not running replication tests. goraft has some rough edges")
|
||||
}
|
||||
|
||||
servers := startAndVerifyCluster(2, c)
|
||||
defer clean(servers...)
|
||||
|
||||
|
@ -191,10 +184,6 @@ func (self *CoordinatorSuite) TestCanCreateCoordinatorsAndReplicate(c *C) {
|
|||
}
|
||||
|
||||
func (self *CoordinatorSuite) TestDoWriteOperationsFromNonLeaderServer(c *C) {
|
||||
if !*noSkipReplicationTests {
|
||||
c.Skip("Not running replication tests. goraft has some rough edges")
|
||||
}
|
||||
|
||||
servers := startAndVerifyCluster(2, c)
|
||||
|
||||
err := servers[1].CreateDatabase("db3", uint8(1))
|
||||
|
@ -222,10 +211,6 @@ func (self *CoordinatorSuite) TestNewServerJoiningClusterWillPickUpData(c *C) {
|
|||
}
|
||||
|
||||
func (self *CoordinatorSuite) TestCanElectNewLeaderAndRecover(c *C) {
|
||||
if !*noSkipReplicationTests {
|
||||
c.Skip("Not running replication tests. goraft has some rough edges")
|
||||
}
|
||||
|
||||
servers := startAndVerifyCluster(3, c)
|
||||
defer clean(servers...)
|
||||
|
||||
|
@ -447,10 +432,6 @@ func (self *CoordinatorSuite) TestDbUserOperations(c *C) {
|
|||
}
|
||||
|
||||
func (self *CoordinatorSuite) TestUserDataReplication(c *C) {
|
||||
if !*noSkipReplicationTests {
|
||||
c.Skip("Not running replication tests. goraft has some rough edges")
|
||||
}
|
||||
|
||||
servers := startAndVerifyCluster(3, c)
|
||||
defer clean(servers...)
|
||||
|
||||
|
@ -488,10 +469,6 @@ func (self *CoordinatorSuite) createDatabases(servers []*RaftServer, c *C) {
|
|||
}
|
||||
|
||||
func (self *CoordinatorSuite) TestCanCreateDatabaseWithNameAndReplicationFactor(c *C) {
|
||||
if !*noSkipReplicationTests {
|
||||
c.Skip("Not running replication tests. goraft has some rough edges")
|
||||
}
|
||||
|
||||
servers := startAndVerifyCluster(3, c)
|
||||
defer clean(servers...)
|
||||
|
||||
|
@ -511,10 +488,6 @@ func (self *CoordinatorSuite) TestCanCreateDatabaseWithNameAndReplicationFactor(
|
|||
}
|
||||
|
||||
func (self *CoordinatorSuite) TestCanDropDatabaseWithName(c *C) {
|
||||
if !*noSkipReplicationTests {
|
||||
c.Skip("Not running replication tests. goraft has some rough edges")
|
||||
}
|
||||
|
||||
servers := startAndVerifyCluster(3, c)
|
||||
defer clean(servers...)
|
||||
|
||||
|
@ -568,10 +541,6 @@ func (self *CoordinatorSuite) TestCheckReadAccess(c *C) {
|
|||
}
|
||||
|
||||
func (self *CoordinatorSuite) TestServersGetUniqueIdsAndCanActivateCluster(c *C) {
|
||||
if !*noSkipReplicationTests {
|
||||
c.Skip("Not running replication tests. goraft has some rough edges")
|
||||
}
|
||||
|
||||
servers := startAndVerifyCluster(3, c)
|
||||
defer clean(servers...)
|
||||
|
||||
|
@ -593,10 +562,6 @@ func (self *CoordinatorSuite) TestServersGetUniqueIdsAndCanActivateCluster(c *C)
|
|||
}
|
||||
|
||||
func (self *CoordinatorSuite) TestCanJoinAClusterWhenNotInitiallyPointedAtLeader(c *C) {
|
||||
if !*noSkipReplicationTests {
|
||||
c.Skip("Not running replication tests. goraft has some rough edges")
|
||||
}
|
||||
|
||||
servers := startAndVerifyCluster(2, c)
|
||||
newServer := newConfigAndServer(c)
|
||||
defer clean(newServer)
|
||||
|
|
Loading…
Reference in New Issue