mirror
/
redis
mirror of https://github.com/go-redis/redis.git
1
0
Fork 1
Code Issues Packages Projects Releases Wiki Activity

More comments.

This commit is contained in:
Vladimir Mihailenco 2015-05-23 18:17:45 +03:00
parent 7b1eeda9c1
commit b1946ee532
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
pubsub.go
View File

@ -26,6 +26,7 @@ func (c *Client) Publish(channel, message string) *IntCmd {
return req return req
} }
// Message received as result of a PUBLISH command issued by another client.
type Message struct { type Message struct {
Channel string Channel string
Payload string Payload string
@ -35,6 +36,8 @@ func (m *Message) String() string {
return fmt.Sprintf("Message<%s: %s>", m.Channel, m.Payload) return fmt.Sprintf("Message<%s: %s>", m.Channel, m.Payload)
} }
// Message matching a pattern-matching subscription received as result
// of a PUBLISH command issued by another client.
type PMessage struct { type PMessage struct {
Channel string Channel string
Pattern string Pattern string
@ -45,10 +48,14 @@ func (m *PMessage) String() string {
return fmt.Sprintf("PMessage<%s: %s>", m.Channel, m.Payload) return fmt.Sprintf("PMessage<%s: %s>", m.Channel, m.Payload)
} }
// Message received after a successful subscription to channel.
type Subscription struct { type Subscription struct {
Kind string // Can be "subscribe", "unsubscribe", "psubscribe" or "punsubscribe".
Kind string
// Channel name we have subscribed to.
Channel string Channel string
Count int // Number of channels we are currently subscribed to.
Count int
} }
func (m *Subscription) String() string { func (m *Subscription) String() string {