golnats

Documentation

Index

• type Nats
  • func PubSub(natsURL string, subject string) Nats
  • func (natsClient *Nats) Close()
  • func (natsClient *Nats) Connect(natsURL string) (err error)
  • func (natsClient *Nats) Log()
  • func (natsClient *Nats) Publish() (err error)
  • func (natsClient *Nats) PublishMessage() (err error)
  • func (natsClient *Nats) Reply() (err error)
  • func (natsClient *Nats) Request() (err error)
  • func (natsClient *Nats) SubscriberAsync() (err error)
  • func (natsClient *Nats) SubscriberChan() (err error)
  • func (natsClient *Nats) SubscriberSync() (err error)
  • func (natsClient *Nats) Unsubscribe()

Types

type Nats

type Nats struct {
	Connection   *nats.Conn
	Subscription *nats.Subscription
	Channel      chan *nats.Msg
	Subject      string
	Message      []byte
	MsgReply     string
	Timeout      time.Duration
}

func PubSub

func PubSub(natsURL string, subject string) Nats

func (*Nats) Close

func (natsClient *Nats) Close()

func (*Nats) Connect

func (natsClient *Nats) Connect(natsURL string) (err error)

func (*Nats) Log

func (natsClient *Nats) Log()

func (*Nats) Publish

func (natsClient *Nats) Publish() (err error)

func (*Nats) PublishMessage

func (natsClient *Nats) PublishMessage() (err error)

func (*Nats) Reply

func (natsClient *Nats) Reply() (err error)

func (*Nats) Request

func (natsClient *Nats) Request() (err error)

func (*Nats) SubscriberAsync

func (natsClient *Nats) SubscriberAsync() (err error)

func (*Nats) SubscriberChan

func (natsClient *Nats) SubscriberChan() (err error)

func (*Nats) SubscriberSync

func (natsClient *Nats) SubscriberSync() (err error)

func (*Nats) Unsubscribe

func (natsClient *Nats) Unsubscribe()