nats

Documentation

Index

• func NewMessage(id string, topic string, data []byte, vPtr any) miface.Message
• type MessageQueue
  • func NewMessageQueue(logger *zap.Logger, address string) (*MessageQueue, error)
  • func (m *MessageQueue) Publish(topic string, pOpts ...miface.PubOption) error
  • func (m *MessageQueue) Subscribe(topic string, handler miface.SubResponseHandler, sOpts ...miface.SubOption) (miface.Subscription, error)
• type Subscription
  • func NewSubscription(topic string, conn *nats.Conn, deliverySemantics common.DeliverySemantics, ...) (*Subscription, error)
  • func (s *Subscription) IsValid() bool
  • func (s *Subscription) Unsubscribe() error

Functions

func NewMessage

func NewMessage(id string, topic string, data []byte, vPtr any) miface.Message

Types

type MessageQueue

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

func NewMessageQueue

func NewMessageQueue(logger *zap.Logger, address string) (*MessageQueue, error)

func (*MessageQueue) Publish

func (m *MessageQueue) Publish(topic string, pOpts ...miface.PubOption) error

func (*MessageQueue) Subscribe

func (m *MessageQueue) Subscribe(
	topic string,
	handler miface.SubResponseHandler,
	sOpts ...miface.SubOption,
) (miface.Subscription, error)

type Subscription

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

func NewSubscription

func NewSubscription(
	topic string,
	conn *nats.Conn,
	deliverySemantics common.DeliverySemantics,
	queue string,
	handler miface.SubResponseHandler,
	decoder miface.Decoder,
	vPtrFactory miface.ValuePtrFactory,
) (*Subscription, error)

func (*Subscription) IsValid

func (s *Subscription) IsValid() bool

func (*Subscription) Unsubscribe

func (s *Subscription) Unsubscribe() error