Documentation ¶ Index ¶ func NewConn(serviceName, clusterID, natsURL string) (stan.Conn, error) func NewConsumer(logger zerolog.Logger, stan stan.Conn, subject, qGroup string, maxInFlight int, ...) (*consumer, error) Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ func NewConn ¶ func NewConn(serviceName, clusterID, natsURL string) (stan.Conn, error) func NewConsumer ¶ func NewConsumer(logger zerolog.Logger, stan stan.Conn, subject, qGroup string, maxInFlight int, cb cb) (*consumer, error) Types ¶ This section is empty. Source Files ¶ View all Source files consumer.gonew_conn.go Click to show internal directories. Click to hide internal directories.