nats

Oct 10, 2017

Changes in this version

+ func Client(s bandmaster.Service) *nats.Conn

+ func Config(s bandmaster.Service) *nats.Options

+ func New(opts *nats.Options) bandmaster.Service

+ type Env struct

+ Addrs []string

+ AllowReconnect bool

+ DialerTimeout time.Duration

+ MaxPingsOut int

+ MaxReconnect int

+ PingInterval time.Duration

+ ReconnectBufSize int

+ ReconnectWait time.Duration

+ SubChanLen int

+ Timeout time.Duration

+ func NewEnv(prefix string) (*Env, error)

+ func (e *Env) Config() *nats.Options

+ type Service struct

+ func (s *Service) Start(context.Context, map[string]bandmaster.Service) error

+ func (s *Service) Stop(ctx context.Context) error