consumers

Documentation

Index

• func RetryOTP(ormService *beeorm.Engine, gatewayRegistry map[string]otp.IOTPSMSGateway, ...)
• type OTPRetryConsumer
  • func NewOTPRetryConsumer(ormService *beeorm.Engine, maxRetries int, ...) *OTPRetryConsumer
  • func (c *OTPRetryConsumer) Consume(_ *beeorm.Engine, event beeorm.Event) error
  • func (c *OTPRetryConsumer) GetGroupName(suffix *string) string
  • func (c *OTPRetryConsumer) GetQueueName() string

Functions

func RetryOTP

func RetryOTP(ormService *beeorm.Engine, gatewayRegistry map[string]otp.IOTPSMSGateway, retryDTO *otp.RetryDTO, otpTrackerEntity *entity.OTPTrackerEntity, maxRetries int)

Types

type OTPRetryConsumer

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

func NewOTPRetryConsumer

func NewOTPRetryConsumer(ormService *beeorm.Engine, maxRetries int, gatewayRegistry map[string]otp.IOTPSMSGateway) *OTPRetryConsumer

func (*OTPRetryConsumer) Consume

func (c *OTPRetryConsumer) Consume(_ *beeorm.Engine, event beeorm.Event) error

func (*OTPRetryConsumer) GetGroupName

func (c *OTPRetryConsumer) GetGroupName(suffix *string) string

func (*OTPRetryConsumer) GetQueueName

func (c *OTPRetryConsumer) GetQueueName() string