mq

Documentation

Index

• type Nats
  • func NewNats(url string) (*Nats, error)
  • func NewNatsOptions(url string) (*Nats, error)
  • func (n *Nats) Publish(ctx context.Context, subj string, msg interface{}) (err error)
  • func (n *Nats) Subscribe(topic string, h mq.SubscribeHandler, queue ...string) (err error)
• type Stan
  • func NewStan(conn stan.Conn, subOpts ...stan.SubscriptionOption) (*Stan, error)
  • func (n *Stan) Publish(ctx context.Context, subj string, msg interface{}) (err error)
  • func (n *Stan) Subscribe(topic string, h mq.SubscribeHandler, queue ...string) (err error)

Types

type Nats

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

Nats ...

func NewNats

func NewNats(url string) (*Nats, error)

NewNats ..

func NewNatsOptions

func NewNatsOptions(url string) (*Nats, error)

NewNatsOptions ..

func (*Nats) Publish

func (n *Nats) Publish(ctx context.Context, subj string, msg interface{}) (err error)

Publish ...

func (*Nats) Subscribe

func (n *Nats) Subscribe(topic string, h mq.SubscribeHandler, queue ...string) (err error)

Subscribe ...

type Stan

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

Stan ...

func NewStan

func NewStan(conn stan.Conn, subOpts ...stan.SubscriptionOption) (*Stan, error)

NewStan ..

func (*Stan) Publish

func (n *Stan) Publish(ctx context.Context, subj string, msg interface{}) (err error)

Publish ...

func (*Stan) Subscribe

func (n *Stan) Subscribe(topic string, h mq.SubscribeHandler, queue ...string) (err error)

Subscribe ...