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

Merge pull request #900 from N-o-X/master 

Add support for XDEL
This commit is contained in:
Vladimir Mihailenco 2018-11-13 15:19:00 +02:00 committed by GitHub
parent 0064936c5b 3a019aa681
commit effc0c507a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 17 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
commands.go
View File

@ -166,6 +166,7 @@ type Cmdable interface {
SUnion(keys ...string) *StringSliceCmd SUnion(keys ...string) *StringSliceCmd
SUnionStore(destination string, keys ...string) *IntCmd SUnionStore(destination string, keys ...string) *IntCmd
XAdd(a *XAddArgs) *StringCmd XAdd(a *XAddArgs) *StringCmd
XDel(stream string, ids ...string) *IntCmd
XLen(stream string) *IntCmd XLen(stream string) *IntCmd
XRange(stream, start, stop string) *XMessageSliceCmd XRange(stream, start, stop string) *XMessageSliceCmd
XRangeN(stream, start, stop string, count int64) *XMessageSliceCmd XRangeN(stream, start, stop string, count int64) *XMessageSliceCmd
@ -1339,6 +1340,16 @@ func (c *cmdable) XAdd(a *XAddArgs) *StringCmd {
return cmd return cmd
} }
func (c *cmdable) XDel(stream string, ids ...string) *IntCmd {
args := []interface{}{"xdel", stream}
for _, id := range ids {
args = append(args, id)
}
cmd := NewIntCmd(args...)
c.process(cmd)
return cmd
}
func (c *cmdable) XLen(stream string) *IntCmd { func (c *cmdable) XLen(stream string) *IntCmd {
cmd := NewIntCmd("xlen", stream) cmd := NewIntCmd("xlen", stream)
c.process(cmd) c.process(cmd)

6
commands_test.go
View File

@ -3405,6 +3405,12 @@ var _ = Describe("Commands", func() {
})) }))
}) })
It("should XDel", func() {
n, err := client.XDel("stream", "1-0", "2-0", "3-0").Result()
Expect(err).NotTo(HaveOccurred())
Expect(n).To(Equal(int64(3)))
})
It("should XLen", func() { It("should XLen", func() {
n, err := client.XLen("stream").Result() n, err := client.XLen("stream").Result()
Expect(err).NotTo(HaveOccurred()) Expect(err).NotTo(HaveOccurred())