19 Star 82 Fork 8

piaohao / godis

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
克隆/下载
redis_cluster_cmd_test.go 9.66 KB
一键复制 编辑 Web IDE 原始数据 按行查看 历史
piaohao 提交于 2019-07-02 18:37 . 1.improve test cases;
package godis
import (
"github.com/stretchr/testify/assert"
"strings"
"testing"
)
var option1 = &Option{
Host: "localhost",
Port: 7000,
}
func TestRedis_ClusterAddSlots(t *testing.T) {
redis := NewRedis(option1)
defer redis.Close()
slots, err := redis.ClusterAddSlots(10000)
assert.NotNil(t, err)
assert.Equal(t, "", slots)
redisBroken := NewRedis(option1)
defer redisBroken.Close()
m, _ := redisBroken.Multi()
_, err = redisBroken.ClusterAddSlots(10000)
assert.NotNil(t, err)
m.Discard()
redisBroken.client.connection.host = "localhost1"
redisBroken.Close()
_, err = redisBroken.ClusterAddSlots(10000)
assert.NotNil(t, err)
}
func TestRedis_ClusterCountKeysInSlot(t *testing.T) {
redis := NewRedis(option1)
defer redis.Close()
slots, err := redis.ClusterCountKeysInSlot(10000)
assert.Nil(t, err)
assert.Equal(t, int64(0), slots)
redisBroken := NewRedis(option1)
defer redisBroken.Close()
m, _ := redisBroken.Multi()
_, err = redisBroken.ClusterCountKeysInSlot(10000)
assert.NotNil(t, err)
m.Discard()
redisBroken.client.connection.host = "localhost1"
redisBroken.Close()
_, err = redisBroken.ClusterCountKeysInSlot(10000)
assert.NotNil(t, err)
}
func TestRedis_ClusterDelSlots(t *testing.T) {
redis := NewRedis(option)
defer redis.Close()
slots, err := redis.ClusterDelSlots(10000)
assert.NotNil(t, err)
assert.Equal(t, "", slots)
redisBroken := NewRedis(option1)
defer redisBroken.Close()
m, _ := redisBroken.Multi()
_, err = redisBroken.ClusterDelSlots(10000)
assert.NotNil(t, err)
m.Discard()
redisBroken.client.connection.host = "localhost1"
redisBroken.Close()
_, err = redisBroken.ClusterDelSlots(10000)
assert.NotNil(t, err)
}
func TestRedis_ClusterFailover(t *testing.T) {
redis := NewRedis(option1)
defer redis.Close()
slots, err := redis.ClusterFailOver()
assert.NotNil(t, err)
assert.Equal(t, "", slots)
redisBroken := NewRedis(option1)
defer redisBroken.Close()
m, _ := redisBroken.Multi()
_, err = redisBroken.ClusterFailOver()
assert.NotNil(t, err)
m.Discard()
redisBroken.client.connection.host = "localhost1"
redisBroken.Close()
_, err = redisBroken.ClusterFailOver()
assert.NotNil(t, err)
}
func TestRedis_ClusterFlushSlots(t *testing.T) {
redis := NewRedis(option)
defer redis.Close()
slots, err := redis.ClusterFlushSlots()
assert.NotNil(t, err)
assert.Equal(t, "", slots)
redisBroken := NewRedis(option1)
defer redisBroken.Close()
m, _ := redisBroken.Multi()
_, err = redisBroken.ClusterFlushSlots()
assert.NotNil(t, err)
m.Discard()
redisBroken.client.connection.host = "localhost1"
redisBroken.Close()
_, err = redisBroken.ClusterFlushSlots()
assert.NotNil(t, err)
}
func TestRedis_ClusterForget(t *testing.T) {
redis := NewRedis(option1)
defer redis.Close()
_, err := redis.ClusterForget("1")
assert.NotNil(t, err)
redisBroken := NewRedis(option1)
defer redisBroken.Close()
m, _ := redisBroken.Multi()
_, err = redisBroken.ClusterForget("1")
assert.NotNil(t, err)
m.Discard()
redisBroken.client.connection.host = "localhost1"
redisBroken.Close()
_, err = redisBroken.ClusterForget("1")
assert.NotNil(t, err)
}
func TestRedis_ClusterGetKeysInSlot(t *testing.T) {
redis := NewRedis(option)
defer redis.Close()
slots, err := redis.ClusterGetKeysInSlot(1, 1)
assert.NotNil(t, err)
assert.Empty(t, slots)
redisBroken := NewRedis(option1)
defer redisBroken.Close()
m, _ := redisBroken.Multi()
_, err = redisBroken.ClusterGetKeysInSlot(1, 1)
assert.NotNil(t, err)
m.Discard()
redisBroken.client.connection.host = "localhost1"
redisBroken.Close()
_, err = redisBroken.ClusterGetKeysInSlot(1, 1)
assert.NotNil(t, err)
}
func TestRedis_ClusterInfo(t *testing.T) {
redis := NewRedis(option1)
defer redis.Close()
s, err := redis.ClusterInfo()
assert.Nil(t, err)
assert.NotEmpty(t, s)
redisBroken := NewRedis(option1)
defer redisBroken.Close()
m, _ := redisBroken.Multi()
_, err = redisBroken.ClusterInfo()
assert.NotNil(t, err)
m.Discard()
redisBroken.client.connection.host = "localhost1"
redisBroken.Close()
_, err = redisBroken.ClusterInfo()
assert.NotNil(t, err)
}
func TestRedis_ClusterKeySlot(t *testing.T) {
redis := NewRedis(option)
defer redis.Close()
slots, err := redis.ClusterKeySlot("godis")
assert.NotNil(t, err)
assert.Equal(t, int64(0), slots)
redisBroken := NewRedis(option1)
defer redisBroken.Close()
m, _ := redisBroken.Multi()
_, err = redisBroken.ClusterKeySlot("godis")
assert.NotNil(t, err)
m.Discard()
redisBroken.client.connection.host = "localhost1"
redisBroken.Close()
_, err = redisBroken.ClusterKeySlot("godis")
assert.NotNil(t, err)
}
func TestRedis_ClusterMeet(t *testing.T) {
redis := NewRedis(option)
defer redis.Close()
slots, err := redis.ClusterMeet("localhost", 8000)
assert.NotNil(t, err)
assert.Equal(t, "", slots)
redisBroken := NewRedis(option1)
defer redisBroken.Close()
m, _ := redisBroken.Multi()
_, err = redisBroken.ClusterMeet("localhost", 8000)
assert.NotNil(t, err)
m.Discard()
redisBroken.client.connection.host = "localhost1"
redisBroken.Close()
_, err = redisBroken.ClusterMeet("localhost", 8000)
assert.NotNil(t, err)
}
func TestRedis_ClusterNodes(t *testing.T) {
redis := NewRedis(option1)
defer redis.Close()
s, err := redis.ClusterNodes()
assert.Nil(t, err)
assert.NotEmpty(t, s)
//t.Log(s)
nodeID := s[:strings.Index(s, " ")]
redis.ClusterSlaves(nodeID)
//assert.Nil(t, err)
//assert.NotEmpty(t, slaves)
redisBroken := NewRedis(option1)
defer redisBroken.Close()
m, _ := redisBroken.Multi()
_, err = redisBroken.ClusterNodes()
assert.NotNil(t, err)
m.Discard()
redisBroken.client.connection.host = "localhost1"
redisBroken.Close()
_, err = redisBroken.ClusterNodes()
assert.NotNil(t, err)
}
func TestRedis_ClusterReplicate(t *testing.T) {
redis := NewRedis(option)
defer redis.Close()
slots, err := redis.ClusterReplicate("godis")
assert.NotNil(t, err)
assert.Equal(t, "", slots)
redisBroken := NewRedis(option1)
defer redisBroken.Close()
m, _ := redisBroken.Multi()
_, err = redisBroken.ClusterReplicate("godis")
assert.NotNil(t, err)
m.Discard()
redisBroken.client.connection.host = "localhost1"
redisBroken.Close()
_, err = redisBroken.ClusterReplicate("godis")
assert.NotNil(t, err)
}
func TestRedis_ClusterReset(t *testing.T) {
redis := NewRedis(option)
defer redis.Close()
slots, err := redis.ClusterReset(*ResetSoft)
assert.NotNil(t, err)
assert.Equal(t, "", slots)
redisBroken := NewRedis(option1)
defer redisBroken.Close()
m, _ := redisBroken.Multi()
_, err = redisBroken.ClusterReset(*ResetSoft)
assert.NotNil(t, err)
m.Discard()
redisBroken.client.connection.host = "localhost1"
redisBroken.Close()
_, err = redisBroken.ClusterReset(*ResetSoft)
assert.NotNil(t, err)
}
func TestRedis_ClusterSaveConfig(t *testing.T) {
redis := NewRedis(option)
defer redis.Close()
slots, err := redis.ClusterSaveConfig()
assert.NotNil(t, err)
assert.Equal(t, "", slots)
redisBroken := NewRedis(option1)
defer redisBroken.Close()
m, _ := redisBroken.Multi()
_, err = redisBroken.ClusterSaveConfig()
assert.NotNil(t, err)
m.Discard()
redisBroken.client.connection.host = "localhost1"
redisBroken.Close()
_, err = redisBroken.ClusterSaveConfig()
assert.NotNil(t, err)
}
func TestRedis_ClusterSetSlotImporting(t *testing.T) {
redis := NewRedis(option)
defer redis.Close()
slots, err := redis.ClusterSetSlotImporting(1, "godis")
assert.NotNil(t, err)
assert.Equal(t, "", slots)
redisBroken := NewRedis(option1)
defer redisBroken.Close()
m, _ := redisBroken.Multi()
_, err = redisBroken.ClusterSetSlotImporting(1, "godis")
assert.NotNil(t, err)
m.Discard()
redisBroken.client.connection.host = "localhost1"
redisBroken.Close()
_, err = redisBroken.ClusterSetSlotImporting(1, "godis")
assert.NotNil(t, err)
}
func TestRedis_ClusterSetSlotMigrating(t *testing.T) {
redis := NewRedis(option)
defer redis.Close()
slots, err := redis.ClusterSetSlotMigrating(1, "godis")
assert.NotNil(t, err)
assert.Equal(t, "", slots)
redisBroken := NewRedis(option1)
defer redisBroken.Close()
m, _ := redisBroken.Multi()
_, err = redisBroken.ClusterSetSlotMigrating(1, "godis")
assert.NotNil(t, err)
m.Discard()
redisBroken.client.connection.host = "localhost1"
redisBroken.Close()
_, err = redisBroken.ClusterSetSlotMigrating(1, "godis")
assert.NotNil(t, err)
}
func TestRedis_ClusterSetSlotNode(t *testing.T) {
redis := NewRedis(option)
defer redis.Close()
slots, err := redis.ClusterSetSlotNode(1, "godis")
assert.NotNil(t, err)
assert.Equal(t, "", slots)
redisBroken := NewRedis(option1)
defer redisBroken.Close()
m, _ := redisBroken.Multi()
_, err = redisBroken.ClusterSetSlotNode(1, "godis")
assert.NotNil(t, err)
m.Discard()
redisBroken.client.connection.host = "localhost1"
redisBroken.Close()
_, err = redisBroken.ClusterSetSlotNode(1, "godis")
assert.NotNil(t, err)
}
func TestRedis_ClusterSetSlotStable(t *testing.T) {
redis := NewRedis(option)
defer redis.Close()
slots, err := redis.ClusterSetSlotStable(1)
assert.NotNil(t, err)
assert.Equal(t, "", slots)
redisBroken := NewRedis(option1)
defer redisBroken.Close()
m, _ := redisBroken.Multi()
_, err = redisBroken.ClusterSetSlotStable(1)
assert.NotNil(t, err)
m.Discard()
redisBroken.client.connection.host = "localhost1"
redisBroken.Close()
_, err = redisBroken.ClusterSetSlotStable(1)
assert.NotNil(t, err)
}
func TestRedis_ClusterSlots(t *testing.T) {
redis := NewRedis(option1)
defer redis.Close()
s, err := redis.ClusterSlots()
assert.Nil(t, err)
assert.NotEmpty(t, s)
redisBroken := NewRedis(option1)
defer redisBroken.Close()
m, _ := redisBroken.Multi()
_, err = redisBroken.ClusterSlots()
assert.NotNil(t, err)
m.Discard()
redisBroken.client.connection.host = "localhost1"
redisBroken.Close()
_, err = redisBroken.ClusterSlots()
assert.NotNil(t, err)
}
Go
1
https://gitee.com/piaohao/godis.git
git@gitee.com:piaohao/godis.git
piaohao
godis
godis
master

搜索帮助

14c37bed 8189591 565d56ea 8189591