forked from mirror/redis
commands: add cluster reset function.
This commit is contained in:
parent
781f7f803d
commit
e335934332
12
commands.go
12
commands.go
|
@ -1666,6 +1666,18 @@ func (c *commandable) ClusterReplicate(nodeID string) *StatusCmd {
|
||||||
return cmd
|
return cmd
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (c *commandable) ClusterResetSoft() *StatusCmd {
|
||||||
|
cmd := newKeylessStatusCmd("CLUSTER", "reset", "soft")
|
||||||
|
c.Process(cmd)
|
||||||
|
return cmd
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c *commandable) ClusterResetHard() *StatusCmd {
|
||||||
|
cmd := newKeylessStatusCmd("CLUSTER", "reset", "hard")
|
||||||
|
c.Process(cmd)
|
||||||
|
return cmd
|
||||||
|
}
|
||||||
|
|
||||||
func (c *commandable) ClusterInfo() *StringCmd {
|
func (c *commandable) ClusterInfo() *StringCmd {
|
||||||
cmd := NewStringCmd("CLUSTER", "info")
|
cmd := NewStringCmd("CLUSTER", "info")
|
||||||
cmd._clusterKeyPos = 0
|
cmd._clusterKeyPos = 0
|
||||||
|
|
Loading…
Reference in New Issue