nats

Documentation

Index

• Constants
• Variables
• 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) CloseConnection()
  • func (n *Nats) ConnectedEndpoints() (endpoints []string)
  • func (in *Nats) DeepCopy() *Nats
  • func (in *Nats) DeepCopyInto(out broker.Handler)
  • func (in *Nats) DeepCopyObject() broker.Handler
  • func (n *Nats) Info() string
  • func (in *Nats) IsEmpty() bool
  • 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        = "meshkit-11118"
	ErrEncodedConnCode    = "meshkit-11119"
	ErrPublishCode        = "meshkit-11120"
	ErrPublishRequestCode = "meshkit-11121"
	ErrQueueSubscribeCode = "meshkit-11122"
)

Variables

var (
	NewEmptyConnection = &Nats{}
)

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) CloseConnection

func (n *Nats) CloseConnection()

func (*Nats) ConnectedEndpoints

func (n *Nats) ConnectedEndpoints() (endpoints []string)

func (*Nats) DeepCopy

func (in *Nats) DeepCopy() *Nats

DeepCopy is a deepcopy function, copying the receiver, creating a new Nats.

func (*Nats) DeepCopyInto

func (in *Nats) DeepCopyInto(out broker.Handler)

DeepCopyInto is a deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Nats) DeepCopyObject

func (in *Nats) DeepCopyObject() broker.Handler

DeepCopyObject is a deepcopy function, copying the receiver, creating a new broker.Handler.

func (*Nats) Info

func (n *Nats) Info() string

func (*Nats) IsEmpty

func (in *Nats) IsEmpty() bool

Check if the connection object is empty

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
}