nats

Documentation

Index

• Constants
• type Nats
  • func NewNats(url string) *Nats
  • func (q *Nats) Broadcast(topic string, data []byte) error
  • func (q *Nats) Close()
  • func (q *Nats) Connect()
  • func (q *Nats) GetSub(topic string) *nats.Subscription
  • func (q *Nats) Request(topic string, data []byte) (*nats.Msg, error)
  • func (q *Nats) SetGlobalTimeout(t time.Duration)
  • func (q *Nats) SetTopicTimeout(topic string, t time.Duration)
  • func (q *Nats) Subscribe(topic string) *nats.Subscription
  • func (q *Nats) SubscribeCall(topic string, f func(msg *nats.Msg)) *nats.Subscription
  • func (q *Nats) SubscribeChan(topic string, ch chan *nats.Msg) *nats.Subscription
  • func (q *Nats) SubscribeQueue(topic, queue string) *nats.Subscription
  • func (q *Nats) UnSubscribe(topics ...string) []string

Constants

const DefaultURL = "nats://127.0.0.1:4222"

Types

type Nats

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

func NewNats

func NewNats(url string) *Nats

func (*Nats) Broadcast

func (q *Nats) Broadcast(topic string, data []byte) error

Broadcast 广播

func (*Nats) Close

func (q *Nats) Close()

func (*Nats) Connect

func (q *Nats) Connect()

func (*Nats) GetSub

func (q *Nats) GetSub(topic string) *nats.Subscription

func (*Nats) Request

func (q *Nats) Request(topic string, data []byte) (*nats.Msg, error)

Request 请求回复

func (*Nats) SetGlobalTimeout

func (q *Nats) SetGlobalTimeout(t time.Duration)

func (*Nats) SetTopicTimeout

func (q *Nats) SetTopicTimeout(topic string, t time.Duration)

func (*Nats) Subscribe

func (q *Nats) Subscribe(topic string) *nats.Subscription

Subscribe 订阅

func (*Nats) SubscribeCall

func (q *Nats) SubscribeCall(topic string, f func(msg *nats.Msg)) *nats.Subscription

SubscribeCall 订阅

func (*Nats) SubscribeChan

func (q *Nats) SubscribeChan(topic string, ch chan *nats.Msg) *nats.Subscription

SubscribeChan 订阅

func (*Nats) SubscribeQueue

func (q *Nats) SubscribeQueue(topic, queue string) *nats.Subscription

SubscribeQueue 订阅队列模式

func (*Nats) UnSubscribe

func (q *Nats) UnSubscribe(topics ...string) []string

UnSubscribe 取消订阅