Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

pubsub

package

Go to main page

Versions in this module

v2

v2.5.0

Jun 20, 2016

v2.4.2

Feb 20, 2016

v2.4.1

Feb 17, 2016

Changes in this version

+ const ClosedState

+ const ClosingState

+ const ConnectedState

+ const DisconnectedState

+ type Client struct

+ func New(pool *redis.Pool, reconnectPolicy conn.ReconnectPolicy) *Client

+ func (c *Client) Connect()

+ func (c *Client) GetState() uint8

+ func (c *Client) Listener(kind ListenerType, event string) *Listener

+ func (c *Client) Subscribe(listener *Listener)

+ func (c *Client) TearDown()

+ func (c *Client) Unsubscribe(listener *Listener)

+ func (e *Client) On(ev EventType, h EventHandler)

+ func (e *Client) OnChannel(ev EventType) chan Event

+ func (e *Client) Once(ev EventType, h EventHandler)

+ func (e *Client) WaitFor(ev EventType)

+ type Event struct

+ Packet interface{}

+ Type EventType

+ type EventHandler func(Event)

+ type EventType uint8

+ const AnyEvent

+ const ClosedEvent

+ const ClosingEvent

+ const ConnectedEvent

+ const DisconnectedEvent

+ const ErrorEvent

+ const MessageEvent

+ const SubscribeEvent

+ const UnsubscribeEvent

+ type Listener struct

+ Active bool

+ Client *Client

+ Event string

+ Messages chan redis.Message

+ PMessages chan redis.PMessage

+ Type ListenerType

+ func (l *Listener) Resubscribe()

+ func (l *Listener) Unsubscribe()

+ type ListenerType uint8

+ const Channel

+ const Pattern