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)

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)