Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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 ¶ added in v1.3.92
type ReindexConsumer struct {
// contains filtered or unexported fields
}
func NewReindexConsumer ¶ added in v1.3.92
func NewReindexConsumer(redisearch *redisearch.RedisSearchEngine) *ReindexConsumer
func (*ReindexConsumer) Consume ¶ added in v1.3.92
func (c *ReindexConsumer) Consume(_ *datalayer.ORM, event beeorm.Event) error
func (*ReindexConsumer) GetGroupName ¶ added in v1.3.92
func (c *ReindexConsumer) GetGroupName(suffix *string) string
func (*ReindexConsumer) GetQueueName ¶ added in v1.3.92
func (c *ReindexConsumer) GetQueueName() string
Click to show internal directories.
Click to hide internal directories.