consumers

package
v1.3.51 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 9, 2023 License: GPL-3.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL