nats_handlers

Documentation

Index

• type NatsReqReplyService
  • func NewNatsReqReplyService(eventEmitter *infrastructure.EventEmitter, kw *kafka.Writer, db *gorm.DB, ...) *NatsReqReplyService
  • func (svc *NatsReqReplyService) CloseResponder() error
  • func (svc *NatsReqReplyService) InitAndRegisterResponder(ctx context.Context, respondeFn func(m *nats.Msg) (string, error))
  • func (svc *NatsReqReplyService) InitEventHandlers()
  • func (svc *NatsReqReplyService) RespondEchoIncomingText(m *nats.Msg) (string, error)

Types

type NatsReqReplyService

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

func NewNatsReqReplyService

func NewNatsReqReplyService(
	eventEmitter *infrastructure.EventEmitter,
	kw *kafka.Writer,
	db *gorm.DB,
	rdb *redis.Client,
	s3Client *s3.S3,
	natsClient *nats.Conn,
) *NatsReqReplyService

func (*NatsReqReplyService) CloseResponder

func (svc *NatsReqReplyService) CloseResponder() error

func (*NatsReqReplyService) InitAndRegisterResponder

func (svc *NatsReqReplyService) InitAndRegisterResponder(ctx context.Context, respondeFn func(m *nats.Msg) (string, error))

func (*NatsReqReplyService) InitEventHandlers

func (svc *NatsReqReplyService) InitEventHandlers()

func (*NatsReqReplyService) RespondEchoIncomingText

func (svc *NatsReqReplyService) RespondEchoIncomingText(m *nats.Msg) (string, error)