nats

Documentation

Index

• type ConfigNats
• type Item
• type Nats
  • func New(cfg *ConfigNats) *Nats
  • func (db *Nats) Down() error
  • func (db *Nats) PubSub(subject, queue string, cb func([]byte) ([]byte, error)) error
  • func (db *Nats) Publish(subject string, v interface{}) error
  • func (db *Nats) Request(subject string, in, out interface{}, timeout time.Duration) error
  • func (db *Nats) Subscribe(subject, queue string, cb interface{}) error
  • func (db *Nats) SubscribeWithContext(ctx context.Context, subject, queue string, cb interface{}) error
  • func (db *Nats) Up() error

Types

type ConfigNats

type ConfigNats struct {
	Conn []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) Down

func (db *Nats) Down() error

func (*Nats) PubSub

func (db *Nats) PubSub(subject, queue string, cb func([]byte) ([]byte, error)) error

func (*Nats) Publish

func (db *Nats) Publish(subject string, v interface{}) error

func (*Nats) Request

func (db *Nats) Request(subject string, in, out interface{}, timeout time.Duration) error

func (*Nats) Subscribe

func (db *Nats) Subscribe(subject, queue string, cb interface{}) error

func (*Nats) SubscribeWithContext

func (db *Nats) SubscribeWithContext(ctx context.Context, subject, queue string, cb interface{}) error

func (*Nats) Up

func (db *Nats) Up() error