mq

Documentation

Index

• type Nats
  • func (n *Nats) Connect() error
  • func (n *Nats) Disconnect()
  • func (n *Nats) GetConfig() NatsConfig
  • func (n *Nats) GetConn() *nats.Conn
  • func (n *Nats) Init() (*Nats, error)
  • func (n *Nats) SendMessage(subject string, data any) error
  • func (n *Nats) SendRequest(subject string, data any, result any) error
• type NatsConfig
  • func (n *NatsConfig) FromEnv() (*NatsConfig, error)
  • func (n *NatsConfig) IsSet() bool

Types

type Nats

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

Nats creates and manages the nats message queue connection

func (*Nats) Connect

func (n *Nats) Connect() error

Connect to the nats server

func (*Nats) Disconnect

func (n *Nats) Disconnect()

Disconnect from the nats server

func (*Nats) GetConfig

func (n *Nats) GetConfig() NatsConfig

GetConfig get the nats config

func (*Nats) GetConn

func (n *Nats) GetConn() *nats.Conn

GetConn retrieves the raw nats connection

func (*Nats) Init

func (n *Nats) Init() (*Nats, error)

Init create a new nats manager with a given config

func (*Nats) SendMessage

func (n *Nats) SendMessage(subject string, data any) error

SendMessage sends a request and captures the error

func (*Nats) SendRequest

func (n *Nats) SendRequest(subject string, data any, result any) error

SendRequest sends a request and captures the error

type NatsConfig

type NatsConfig struct {
	Host string
	User string
	Pass string
}

NatsConfig configuration structure for the nats mq

func (*NatsConfig) FromEnv

func (n *NatsConfig) FromEnv() (*NatsConfig, error)

FromEnv creates a nats config using environmental variables

func (*NatsConfig) IsSet

func (n *NatsConfig) IsSet() bool

IsSet checks if the configuration has been set Note: All fields required