Documentation ¶
Index ¶
Constants ¶
View Source
const ( // DefaultReconnectInterval ... DefaultReconnectInterval = 2 // DefaultMaxReconnectInterval ... DefaultMaxReconnectInterval = 64 )
Variables ¶
View Source
var ( // PublishedRegexp ... PublishedRegexp = regexp.MustCompile( "message successfully published to \\w+ with sequence \\d", ) )
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client ...
func (*Client) Subscribe ¶
func (c *Client) Subscribe(topic string, handler msgbus.HandlerFunc) *Subscriber
Subscribe ...
type Subscriber ¶
Subscriber ...
func NewSubscriber ¶
func NewSubscriber(client *Client, topic string, handler msgbus.HandlerFunc) *Subscriber
NewSubscriber ...
Click to show internal directories.
Click to hide internal directories.