nats

Documentation

Index

• type Config
• type MQ
  • func New() *MQ
  • func (mq *MQ) Init(ctx context.Context, log logger.Logger) error
  • func (mq *MQ) Publish(_ context.Context, _ string, routingKey, payload []byte) error
  • func (mq *MQ) Subscribe(ctx context.Context, target string, message query.Response) error
  • func (mq *MQ) UnSubscribe(name string) error

Types

type Config

type Config struct {
	URI         *url.URL
	ChannelSize int
}

Config - configuration

type MQ

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

func New

func New() *MQ

func (*MQ) Init

func (mq *MQ) Init(ctx context.Context, log logger.Logger) error

func (*MQ) Publish

func (mq *MQ) Publish(_ context.Context, _ string, routingKey, payload []byte) error

Publish - publish a message

func (*MQ) Subscribe

func (mq *MQ) Subscribe(ctx context.Context, target string, message query.Response) error

Subscribe - subscribe to message

func (*MQ) UnSubscribe

func (mq *MQ) UnSubscribe(name string) error

UnSubscribe - unsubscribe from message