Versions in this module Expand all Collapse all v0 v0.1.1 May 8, 2018 v0.1.0 May 8, 2018 Changes in this version + const DefaultMaxReconnectInterval + const DefaultReconnectInterval + var PublishedRegexp = regexp.MustCompile("message successfully published to \\w+ with sequence \\d") + type Client struct + func NewClient(url string, options *Options) *Client + func (c *Client) Handle(msg *msgbus.Message) error + func (c *Client) Publish(topic, message string) error + func (c *Client) Pull(topic string) (msg *msgbus.Message, err error) + func (c *Client) Subscribe(topic string, handler msgbus.HandlerFunc) *Subscriber + type Options struct + MaxReconnectInterval int + ReconnectInterval int + type Subscriber struct + func NewSubscriber(client *Client, topic string, handler msgbus.HandlerFunc) *Subscriber + func (s *Subscriber) Start() + func (s *Subscriber) Stop()
Go to main page