consumers

Documentation

Index

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

Functions

func RetryOTP

func RetryOTP(
	ormService *datalayer.ORM,
	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 *datalayer.ORM, maxRetries int, gatewayRegistry map[string]otp.IOTPSMSGateway) *OTPRetryConsumer

func (*OTPRetryConsumer) Consume

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

func (*OTPRetryConsumer) GetGroupName

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

func (*OTPRetryConsumer) GetQueueName

func (c *OTPRetryConsumer) GetQueueName() string

type ReindexConsumer

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

func NewReindexConsumer

func NewReindexConsumer(redisearch *redisearch.RedisSearchEngine) *ReindexConsumer

func (*ReindexConsumer) Consume

func (c *ReindexConsumer) Consume(_ *datalayer.ORM, event beeorm.Event) error

func (*ReindexConsumer) GetGroupName

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

func (*ReindexConsumer) GetQueueName

func (c *ReindexConsumer) GetQueueName() string