代码拉取完成,页面将自动刷新
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)
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。