nats

Documentation

Index

• Constants
• func ErrConnect(err error) error
• func ErrEncodedConn(err error) error
• func ErrPublish(err error) error
• func ErrPublishRequest(err error) error
• func ErrQueueSubscribe(err error) error
• func New(opts Options) (broker.Handler, error)
• type Nats
  • func (n *Nats) Info() string
  • func (n *Nats) Publish(subject string, message *broker.Message) error
  • func (n *Nats) PublishWithChannel(subject string, msgch chan *broker.Message) error
  • func (n *Nats) Subscribe(subject, queue string, message []byte) error
  • func (n *Nats) SubscribeWithChannel(subject, queue string, msgch chan *broker.Message) error
• type Options

Constants

const (
	ErrConnectCode        = "11000"
	ErrEncodedConnCode    = "11000"
	ErrPublishCode        = "11001"
	ErrPublishRequestCode = "11001"
	ErrQueueSubscribeCode = "11001"
)

Functions

func ErrConnect

func ErrConnect(err error) error

func ErrEncodedConn

func ErrEncodedConn(err error) error

func ErrPublish

func ErrPublish(err error) error

func ErrPublishRequest

func ErrPublishRequest(err error) error

func ErrQueueSubscribe

func ErrQueueSubscribe(err error) error

func New

func New(opts Options) (broker.Handler, error)

New - constructor

Types

type Nats

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

Nats will implement Nats subscribe and publish functionality

func (*Nats) Info

func (n *Nats) Info() string

func (*Nats) Publish

func (n *Nats) Publish(subject string, message *broker.Message) error

Publish - to publish messages

func (*Nats) PublishWithChannel

func (n *Nats) PublishWithChannel(subject string, msgch chan *broker.Message) error

PublishWithChannel - to publish messages with channel

func (*Nats) Subscribe

func (n *Nats) Subscribe(subject, queue string, message []byte) error

Subscribe - for subscribing messages TODO Ques: Do we want to unsubscribe TODO will the method-user just subsribe, how will it handle the received messages?

func (*Nats) SubscribeWithChannel

func (n *Nats) SubscribeWithChannel(subject, queue string, msgch chan *broker.Message) error

SubscribeWithChannel will publish all the messages received to the given channel

type Options

type Options struct {
	URLS           []string
	ConnectionName string
	Username       string
	Password       string
	ReconnectWait  time.Duration
	MaxReconnect   int
}