nats

Apr 27, 2021

Changes in this version

type Config

+ Token string

Apr 23, 2021

Changes in this version

type Config

+ Password string

+ Username string

Jul 3, 2020

Changes in this version

+ const DefaultConnectTimeout

+ const DefaultDrainTimeout

+ const DefaultMaxReconnect

+ const DefaultReconnectWait

+ type Broker struct

+ func NewBroker(conf *Config) (*Broker, error)

+ func (b *Broker) Connect() error

+ func (b *Broker) Debug(l logger.Logger)

+ func (b *Broker) Disconnect() error

+ func (b *Broker) Pub(topic string, e *event.Event) error

+ func (b *Broker) Sub(topic string, h bus.EventHandler) error

+ type Config struct

+ ConnectTimeout int

+ DrainTimeout int

+ MaxReconnect int

+ ReconnectWait int

+ Servers []string

+ func NewDefaultConfig() *Config

+ func (c *Config) GetConnectTimeout() time.Duration

+ func (c *Config) GetDrainTimeout() time.Duration

+ func (c *Config) GetMaxReconnect() int

+ func (c *Config) GetReconnectWait() time.Duration

+ func (c *Config) Validate() error