From f3663987c0c01fa33d710fadb07f3737315c4a1e Mon Sep 17 00:00:00 2001 From: Mattias Lundell Date: Thu, 9 Jun 2016 17:39:51 +0200 Subject: [PATCH] add support for SPOP with a count argument (available in REDIS 3.2) --- commands.go | 8 ++++++++ commands_test.go | 28 ++++++++++++++++++++++++++++ 2 files changed, 36 insertions(+) diff --git a/commands.go b/commands.go index cf61c20..342fb1f 100644 --- a/commands.go +++ b/commands.go @@ -959,12 +959,20 @@ func (c *commandable) SMove(source, destination string, member interface{}) *Boo return cmd } +// Redis `SPOP key` command. func (c *commandable) SPop(key string) *StringCmd { cmd := NewStringCmd("SPOP", key) c.Process(cmd) return cmd } +// Redis `SPOP key count` command. +func (c *commandable) SPopN(key string, count int64) *StringSliceCmd { + cmd := NewStringSliceCmd("SPOP", key, count) + c.Process(cmd) + return cmd +} + // Redis `SRANDMEMBER key` command. func (c *commandable) SRandMember(key string) *StringCmd { cmd := NewStringCmd("SRANDMEMBER", key) diff --git a/commands_test.go b/commands_test.go index 576389d..21bfd74 100644 --- a/commands_test.go +++ b/commands_test.go @@ -1819,6 +1819,34 @@ var _ = Describe("Commands", func() { sMembers := client.SMembers("set") Expect(sMembers.Err()).NotTo(HaveOccurred()) Expect(sMembers.Val()).To(HaveLen(2)) + + }) + + It("should SPopN", func() { + sAdd := client.SAdd("set", "one") + Expect(sAdd.Err()).NotTo(HaveOccurred()) + sAdd = client.SAdd("set", "two") + Expect(sAdd.Err()).NotTo(HaveOccurred()) + sAdd = client.SAdd("set", "three") + Expect(sAdd.Err()).NotTo(HaveOccurred()) + sAdd = client.SAdd("set", "four") + Expect(sAdd.Err()).NotTo(HaveOccurred()) + + sPopN := client.SPopN("set", 1) + Expect(sPopN.Err()).NotTo(HaveOccurred()) + Expect(sPopN.Val()).NotTo(Equal([]string{""})) + + sMembers := client.SMembers("set") + Expect(sMembers.Err()).NotTo(HaveOccurred()) + Expect(sMembers.Val()).To(HaveLen(3)) + + sPopN = client.SPopN("set", 4) + Expect(sPopN.Err()).NotTo(HaveOccurred()) + Expect(sPopN.Val()).To(HaveLen(3)) + + sMembers = client.SMembers("set") + Expect(sMembers.Err()).NotTo(HaveOccurred()) + Expect(sMembers.Val()).To(HaveLen(0)) }) It("should SRandMember and SRandMemberN", func() {