mq

Documentation

Index

• type Nats
  • func NewNats(logger *zap.Logger) *Nats
  • func (n *Nats) Close() error
  • func (n *Nats) Publish(topic string, data []byte) error
  • func (n *Nats) QueueSubscribe(topic, queue string, handler func(msg *nats.Msg)) error
  • func (n *Nats) Start(addrs []string) error
  • func (n *Nats) Subscribe(topic string, handler func(msg *nats.Msg)) error

Types

type Nats

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

Nats nats struct

func NewNats

func NewNats(logger *zap.Logger) *Nats

NewNats return new nats

func (*Nats) Close

func (n *Nats) Close() error

Close close nats

func (*Nats) Publish

func (n *Nats) Publish(topic string, data []byte) error

Publish 发布

func (*Nats) QueueSubscribe

func (n *Nats) QueueSubscribe(topic, queue string, handler func(msg *nats.Msg)) error

QueueSubscribe ....

func (*Nats) Start

func (n *Nats) Start(addrs []string) error

Start init && start nats

func (*Nats) Subscribe

func (n *Nats) Subscribe(topic string, handler func(msg *nats.Msg)) error

Subscribe ....