Versions in this module Expand all Collapse all v1 v1.13.1 Feb 8, 2017 Changes in this version + type Publisher struct + func NewPublisher(publishTimeout time.Duration, buffer int) *Publisher + func (p *Publisher) Close() + func (p *Publisher) Evict(sub chan interface{}) + func (p *Publisher) Len() int + func (p *Publisher) Publish(v interface{}) + func (p *Publisher) Subscribe() chan interface{} + func (p *Publisher) SubscribeTopic(topic topicFunc) chan interface{}
Go to main page