Versions in this module Expand all Collapse all v0 v0.3.1 Oct 26, 2015 v0.3.0 Sep 17, 2015 Changes in this version + var ConsoleOpts = &Opts + var DefaultOpts = &Opts + func NewContext(parent context.Context, pubsub *PubSub) context.Context + func Unregister(c context.Context, key interface{}) + type Buffer struct + func NewBuffer(channel *Channel) *Buffer + func (b *Buffer) Bytes() []byte + func (b *Buffer) Write(p []byte) (n int, err error) + func (b *Buffer) WriteString(s string) (n int, err error) + type Channel struct + func Lookup(c context.Context, key interface{}) *Channel + func NewChannel(opts *Opts) *Channel + func Register(c context.Context, key interface{}) *Channel + func RegisterOpts(c context.Context, key interface{}, opts *Opts) *Channel + func (c *Channel) Close() + func (c *Channel) Publish(data interface{}) + func (c *Channel) Subscribe() *Subscription + type Opts struct + Record bool + Timeout time.Duration + type PubSub struct + func FromContext(c context.Context) *PubSub + func NewPubSub() *PubSub + func (b *PubSub) Lookup(key interface{}) *Channel + func (b *PubSub) Register(key interface{}) *Channel + func (b *PubSub) RegisterOpts(key interface{}, opts *Opts) *Channel + func (b *PubSub) Unregister(key interface{}) + type Subscription struct + func NewSubscription(channel *Channel) *Subscription + func (s *Subscription) Close() + func (s *Subscription) CloseNotify() <-chan bool + func (s *Subscription) Read() <-chan interface{}
Go to main page