nats

Documentation

Index

• 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(ctx context.Context, topic string, handler miface.SubResponseHandler, ...) (miface.Subscription, error)
• type Subscription
  • func NewSubscription(ctx context.Context, topic string, conn *nats.Conn, ...) (*Subscription, error)
  • func (s *Subscription) IsValid() bool
  • func (s *Subscription) Unsubscribe() error

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(
	ctx context.Context,
	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(
	ctx context.Context,
	topic string,
	conn *nats.Conn,
	deliverySemantics common.DeliverySemantics,
	queue string,
	handler miface.SubResponseHandler,
) (*Subscription, error)

func (*Subscription) IsValid

func (s *Subscription) IsValid() bool

func (*Subscription) Unsubscribe

func (s *Subscription) Unsubscribe() error