client

Apr 5, 2022

Changes in this version

+ var ErrConnectionFailed = errors.New("error: connection failed")

type Options

+ PingInterval int

type Subscriber

+ func (s *Subscriber) Run(ctx context.Context) error

Mar 27, 2022

Changes in this version

+ const DefaultPingInterval

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()