Versions in this module Expand all Collapse all v1 v1.1.6 Jul 17, 2021 v1.1.5 Jul 17, 2021 Changes in this version + func NewConn(serviceName, clusterID, natsURL string) (stan.Conn, error) + func NewConsumer(logger zerolog.Logger, stan stan.Conn, subject, qGroup string, maxInFlight int, ...) (*consumer, error)