nats

Documentation

Index

• type Nats
  • func InitConnection(natsAddress, username, password string, logger logger.Logger) Nats
  • func (r Nats) GetNatsClient() *nats.Conn
  • func (r Nats) Publish(subject string, body []byte) error
  • func (r Nats) RegisterHandlerConsumerGroup(subject, groupId string, workerCount int, cb nats.MsgHandler) error

Types

type Nats

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

func InitConnection

func InitConnection(natsAddress, username, password string, logger logger.Logger) Nats

func (Nats) GetNatsClient

func (r Nats) GetNatsClient() *nats.Conn

func (Nats) Publish

func (r Nats) Publish(subject string, body []byte) error

func (Nats) RegisterHandlerConsumerGroup

func (r Nats) RegisterHandlerConsumerGroup(subject, groupId string, workerCount int, cb nats.MsgHandler) error