nats

Documentation

Index

• type ConfigNats
• type Item
• type Nats
  • func New(cfg *ConfigNats) *Nats
  • func (db *Nats) Call(fn func(conn *nats.EncodedConn) error) error
  • func (db *Nats) Start() error
  • func (db *Nats) Stop() error

Types

type ConfigNats

type ConfigNats struct {
	DB Item `yaml:"nats"`
}

type Item

type Item struct {
	Host string `yaml:"host"`
	Port int    `yaml:"port"`
}

type Nats

type Nats struct {
	// contains filtered or unexported fields
}

func New

func New(cfg *ConfigNats) *Nats

func (*Nats) Call

func (db *Nats) Call(fn func(conn *nats.EncodedConn) error) error

func (*Nats) Start

func (db *Nats) Start() error

func (*Nats) Stop

func (db *Nats) Stop() error