authevent

Documentation

Index

• Constants
• type SendEmailOTP
  • func NewSendEmailOTP(queue *messagebroker.Queue) *SendEmailOTP
  • func (r *SendEmailOTP) Consume(message []byte) error
  • func (r *SendEmailOTP) Name() string
  • func (r *SendEmailOTP) Publish(message interface{})
  • func (r *SendEmailOTP) Register()
• type SendEmailOTPDto
• type SendResetPasswordLink
  • func NewSendResetPasswordLink(queue *messagebroker.Queue) *SendResetPasswordLink
  • func (r *SendResetPasswordLink) Consume(message []byte) error
  • func (r *SendResetPasswordLink) Name() string
  • func (r *SendResetPasswordLink) Publish(message interface{})
  • func (r *SendResetPasswordLink) Register()
• type SendResetPasswordLinkDto
• type SendWelcome
  • func NewSendWelcome(queue *messagebroker.Queue, userClient port.UserClient) *SendWelcome
  • func (r *SendWelcome) Consume(message []byte) error
  • func (r *SendWelcome) Name() string
  • func (r *SendWelcome) Publish(message interface{})
  • func (r *SendWelcome) Register()
• type SendWelcomeDto

Constants

const DelaySendEmailOTPSeconds int64 = 0

const DelaySendResetPasswordLinkSeconds int64 = 0

const DelaySendWelcomeSeconds int64 = 60

const SendEmailOtpName = "send_email_otp"

const SendResetPasswordLinkName = "send_reset_password_link"

const SendWelcomeName = "send_welcome"

Types

type SendEmailOTP

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

func NewSendEmailOTP

func NewSendEmailOTP(queue *messagebroker.Queue) *SendEmailOTP

func (*SendEmailOTP) Consume

func (r *SendEmailOTP) Consume(message []byte) error

func (*SendEmailOTP) Name

func (r *SendEmailOTP) Name() string

func (*SendEmailOTP) Publish

func (r *SendEmailOTP) Publish(message interface{})

func (*SendEmailOTP) Register

func (r *SendEmailOTP) Register()

type SendEmailOTPDto

type SendEmailOTPDto struct {
	To       string `json:"to"`
	Name     string `json:"name"`
	OTP      string `json:"otp"`
	Language string `json:"language"`
}

type SendResetPasswordLink

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

func NewSendResetPasswordLink

func NewSendResetPasswordLink(queue *messagebroker.Queue) *SendResetPasswordLink

func (*SendResetPasswordLink) Consume

func (r *SendResetPasswordLink) Consume(message []byte) error

func (*SendResetPasswordLink) Name

func (r *SendResetPasswordLink) Name() string

func (*SendResetPasswordLink) Publish

func (r *SendResetPasswordLink) Publish(message interface{})

func (*SendResetPasswordLink) Register

func (r *SendResetPasswordLink) Register()

type SendResetPasswordLinkDto

type SendResetPasswordLinkDto struct {
	To       string `json:"to"`
	Name     string `json:"name"`
	OTP      string `json:"otp"`
	Language string `json:"language"`
}

type SendWelcome

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

func NewSendWelcome

func NewSendWelcome(queue *messagebroker.Queue, userClient port.UserClient) *SendWelcome

func (*SendWelcome) Consume

func (r *SendWelcome) Consume(message []byte) error

func (*SendWelcome) Name

func (r *SendWelcome) Name() string

func (*SendWelcome) Publish

func (r *SendWelcome) Publish(message interface{})

func (*SendWelcome) Register

func (r *SendWelcome) Register()

type SendWelcomeDto

type SendWelcomeDto struct {
	UserID   uint64 `json:"userID"`
	To       string `json:"to"`
	Name     string `json:"name"`
	Language string `json:"language"`
}