nats

Documentation

Index

• type Messaging
  • func NewMessaging(url string, opts ...Option) (*Messaging, error)
  • func (m *Messaging) Publish(subj string, data []byte) error
  • func (m *Messaging) Shutdown()
  • func (m *Messaging) Subscribe(con string, subj string, mh smsg.MsgHandler) error
• type Option
  • func WithTLS(certPath, keyPath, userId, pw string) Option
• type Options

Types

type Messaging

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

This implements smile_messaging_go.Messaging

func NewMessaging

func NewMessaging(url string, opts ...Option) (*Messaging, error)

func (*Messaging) Publish

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

func (*Messaging) Shutdown

func (m *Messaging) Shutdown()

func (*Messaging) Subscribe

func (m *Messaging) Subscribe(con string, subj string, mh smsg.MsgHandler) error

type Option

type Option func(*Options)

An Option is a function operating on the Messaging Options

func WithTLS

func WithTLS(certPath, keyPath, userId, pw string) Option

WithTLS is an Option to enable a TLS channel

type Options

type Options struct {
	UseTLS      bool
	TLSCertPath string
	TLSKeyPath  string
	UserId      string
	Password    string
}

Options for Messaging provider