natsHelper

Documentation

Index

• Variables
• func Subscribe(subject string, cb nats.MsgHandler)
• type NatsConsumer
  • func (n *NatsConsumer) QueueSubscribe(subject string, queue string, cb nats.MsgHandler)
  • func (n *NatsConsumer) Subscribe(subject string, cb nats.MsgHandler)
• type NatsMq
  • func NewNatsMq() *NatsMq
  • func (n *NatsMq) Publish(subject string, content interface{}) error
  • func (n *NatsMq) QueueSubscribe(subject string, queue string, cb nats.MsgHandler)
  • func (n *NatsMq) Reply(subject string, fun func() interface{})
  • func (n *NatsMq) ReplyWithPara(subject string, fun func(m *nats.Msg) interface{})
  • func (n *NatsMq) Request(subject string, content interface{}, timeout time.Duration, v any) error
  • func (n *NatsMq) Subscribe(subject string, cb nats.MsgHandler)
• type NatsProducer
  • func (n *NatsProducer) Publish(subject string, content interface{}) error
  • func (n *NatsProducer) Request(subject string, content interface{}, timeout time.Duration) (*nats.Msg, error)
• type NatsSubscribeInfo

Variables

var Conn *nats.Conn

Functions

func Subscribe

func Subscribe(subject string, cb nats.MsgHandler)

Types

type NatsConsumer

type NatsConsumer struct {
	Conn *nats.Conn
	// contains filtered or unexported fields
}

func (*NatsConsumer) QueueSubscribe

func (n *NatsConsumer) QueueSubscribe(subject string, queue string, cb nats.MsgHandler)

func (*NatsConsumer) Subscribe

func (n *NatsConsumer) Subscribe(subject string, cb nats.MsgHandler)

type NatsMq

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

func NewNatsMq

func NewNatsMq() *NatsMq

func (*NatsMq) Publish

func (n *NatsMq) Publish(subject string, content interface{}) error

func (*NatsMq) QueueSubscribe

func (n *NatsMq) QueueSubscribe(subject string, queue string, cb nats.MsgHandler)

func (*NatsMq) Reply

func (n *NatsMq) Reply(subject string, fun func() interface{})

func (*NatsMq) ReplyWithPara

func (n *NatsMq) ReplyWithPara(subject string, fun func(m *nats.Msg) interface{})

func (*NatsMq) Request

func (n *NatsMq) Request(subject string, content interface{}, timeout time.Duration, v any) error

func (*NatsMq) Subscribe

func (n *NatsMq) Subscribe(subject string, cb nats.MsgHandler)

type NatsProducer

type NatsProducer struct {
	Conn *nats.Conn
}

func (*NatsProducer) Publish

func (n *NatsProducer) Publish(subject string, content interface{}) error

func (*NatsProducer) Request

func (n *NatsProducer) Request(subject string, content interface{}, timeout time.Duration) (*nats.Msg, error)

type NatsSubscribeInfo

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