re
/
redis
forked from mirror/redis
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Added implementation for WAIT command 

Reference: https://redis.io/commands/wait
This commit is contained in:
Nate Bosscher 2017-02-16 11:15:34 -05:00 committed by Vladimir Mihailenco
parent 9405576413
commit 6b8c6b3fe9
2 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
commands.go
View File

@ -273,6 +273,13 @@ func (c *cmdable) Ping() *StatusCmd {
return cmd return cmd
} }
func (c *cmdable) Wait(numSlaves int, timeout time.Duration) *IntCmd {
cmd := NewIntCmd("wait", numSlaves, int(timeout/time.Second))
c.process(cmd)
return cmd
}
func (c *cmdable) Quit() *StatusCmd { func (c *cmdable) Quit() *StatusCmd {
panic("not implemented") panic("not implemented")
} }

7
commands_test.go
View File

@ -50,6 +50,13 @@ var _ = Describe("Commands", func() {
Expect(ping.Val()).To(Equal("PONG")) Expect(ping.Val()).To(Equal("PONG"))
}) })
It("should Wait", func() {
// assume testing on single redis instance
wait := client.Wait(0, time.Minute)
Expect(wait.Err()).NotTo(HaveOccurred())
Expect(wait.Val()).To(Equal(int64(0)))
})
It("should Select", func() { It("should Select", func() {
pipe := client.Pipeline() pipe := client.Pipeline()
sel := pipe.Select(1) sel := pipe.Select(1)