Versions in this module Expand all Collapse all v0 v0.2.1 Jan 10, 2026 v0.2.0 Jan 10, 2026 Changes in this version + func IsConnectionError(err error) bool + type Client struct + Conn *nats.Conn + func New(url string) (*Client, error) + func (c *Client) Close() + func (c *Client) Publish(subject string, data []byte) error + func (c *Client) QueueSubscribe(subject, queue string, handler MsgHandler) (*nats.Subscription, error) + func (c *Client) Subscribe(subject string, handler MsgHandler) (*nats.Subscription, error) + type MsgHandler func(msg *nats.Msg)
Go to main page