Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BarrierMode ¶
func BarrierMode()
func PipelineMode ¶
func PipelineMode()
func ProducerConsumerMode ¶
func ProducerConsumerMode()
Types ¶
type Publisher ¶
type Publisher struct {
// contains filtered or unexported fields
}
发布者对象
func NewPublisher ¶
构建一个发布者对象, 可以设置发布超时时间和缓存队列的长度
func (*Publisher) SubscribeTopic ¶
func (p *Publisher) SubscribeTopic(topic topicFunc) chan interface{}
添加一个新的订阅者,订阅过滤器筛选后的主题
Click to show internal directories.
Click to hide internal directories.