cherryNats

Documentation

Index

• func ChanExecute(subject string, msgChan chan *nats.Msg, process func(msg *nats.Msg))
• func ChanSubscribe(subj string, ch chan *nats.Msg) (*nats.Subscription, error)
• func Close()
• func Init()
• func Publish(subj string, data []byte) error
• func Request(subj string, data []byte, timeout time.Duration) (*nats.Msg, error)
• func Subscribe(subj string, cb nats.MsgHandler) (*nats.Subscription, error)
• type NatsConnect
  • func App() *NatsConnect
  • func New(opts ...OptionFunc) *NatsConnect
  • func (p *NatsConnect) Connect()
  • func (p *NatsConnect) GetNatsOption() []nats.Option
  • func (p *NatsConnect) LoadConfig(config cfacade.JsonConfig)
• type OptionFunc
  • func WithAddress(address string) OptionFunc
  • func WithAuth(user, password string) OptionFunc
  • func WithParams(reconnectDelay int, maxReconnects int, requestTimeout time.Duration) OptionFunc
• type Options

Functions

func ChanExecute

func ChanExecute(subject string, msgChan chan *nats.Msg, process func(msg *nats.Msg))

func ChanSubscribe

func ChanSubscribe(subj string, ch chan *nats.Msg) (*nats.Subscription, error)

func Close

func Close()

func Init

func Init()

func Publish

func Publish(subj string, data []byte) error

func Request

func Request(subj string, data []byte, timeout time.Duration) (*nats.Msg, error)

func Subscribe

func Subscribe(subj string, cb nats.MsgHandler) (*nats.Subscription, error)

Types

type NatsConnect

type NatsConnect struct {
	*nats.Conn
	Options
}

func App

func App() *NatsConnect

func New

func New(opts ...OptionFunc) *NatsConnect

func (*NatsConnect) Connect

func (p *NatsConnect) Connect()

func (*NatsConnect) GetNatsOption

func (p *NatsConnect) GetNatsOption() []nats.Option

func (*NatsConnect) LoadConfig

func (p *NatsConnect) LoadConfig(config cfacade.JsonConfig)

type OptionFunc

type OptionFunc func(opts *Options)

func WithAddress

func WithAddress(address string) OptionFunc

func WithAuth

func WithAuth(user, password string) OptionFunc

func WithParams

func WithParams(reconnectDelay int, maxReconnects int, requestTimeout time.Duration) OptionFunc

type Options

type Options struct {
	Address        string
	ReconnectDelay int
	MaxReconnects  int
	RequestTimeout time.Duration
	User           string
	Password       string
}