update tests to run with v2

This commit is contained in:
Mahmood Ali
2019-08-28 16:42:08 -04:00
parent ae666bb417
commit 8ac5df4056

View File

@@ -125,7 +125,9 @@ func TestOperator_RaftGetConfiguration_ACL(t *testing.T) {
func TestOperator_RaftRemovePeerByAddress(t *testing.T) {
t.Parallel()
s1 := TestServer(t, nil)
s1 := TestServer(t, func(c *Config) {
c.RaftConfig.ProtocolVersion = raft.ProtocolVersion(2)
})
defer s1.Shutdown()
codec := rpcClient(t, s1)
testutil.WaitForLeader(t, s1.RPC)
@@ -181,7 +183,10 @@ func TestOperator_RaftRemovePeerByAddress(t *testing.T) {
func TestOperator_RaftRemovePeerByAddress_ACL(t *testing.T) {
t.Parallel()
s1, root := TestACLServer(t, nil)
s1, root := TestACLServer(t, func(c *Config) {
c.RaftConfig.ProtocolVersion = raft.ProtocolVersion(2)
})
defer s1.Shutdown()
codec := rpcClient(t, s1)
testutil.WaitForLeader(t, s1.RPC)