redis/go-redis
1
0
Fork 0
mirror of https://github.com/redis/go-redis.git synced 2025-06-12 14:21:52 +03:00
Code Activity

Add pubsub* commands.

Browse Source
This commit is contained in:
Vladimir Mihailenco
2014-10-07 13:06:41 +03:00
parent 7aeeecb761
commit a11f80d9d7
2 changed files with 68 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

46
redis_test.go
View File

@ -2562,6 +2562,52 @@ func (t *RedisTest) TestPubSub(c *C) {
}
}
func (t *RedisTest) TestPubSubChannels(c *C) {
channels, err := t.client.PubSubChannels("mychannel*").Result()
c.Assert(err, IsNil)
c.Assert(channels, HasLen, 0)
c.Assert(channels, Not(IsNil))
pubsub := t.client.PubSub()
defer pubsub.Close()
c.Assert(pubsub.Subscribe("mychannel", "mychannel2"), IsNil)
channels, err = t.client.PubSubChannels("mychannel*").Result()
c.Assert(err, IsNil)
c.Assert(sortStrings(channels), DeepEquals, []string{"mychannel", "mychannel2"})
}
func (t *RedisTest) TestPubSubNumSub(c *C) {
pubsub := t.client.PubSub()
defer pubsub.Close()
c.Assert(pubsub.Subscribe("mychannel", "mychannel2"), IsNil)
channels, err := t.client.PubSubNumSub("mychannel", "mychannel2", "mychannel3").Result()
c.Assert(err, IsNil)
c.Assert(
channels,
DeepEquals,
[]string{"mychannel", "1", "mychannel2", "1", "mychannel3", "0"},
)
}
func (t *RedisTest) TestPubSubNumPat(c *C) {
num, err := t.client.PubSubNumPat().Result()
c.Assert(err, IsNil)
c.Assert(num, Equals, int64(0))
pubsub := t.client.PubSub()
defer pubsub.Close()
c.Assert(pubsub.PSubscribe("mychannel*"), IsNil)
num, err = t.client.PubSubNumPat().Result()
c.Assert(err, IsNil)
c.Assert(num, Equals, int64(1))
}
//------------------------------------------------------------------------------
func (t *RedisTest) TestPipeline(c *C) {