task

Documentation

Index

• Constants
• type ErrorInfo
• type QuotaTaskLogic
  • func NewQuotaTaskLogic(svcCtx *svc.ServiceContext) *QuotaTaskLogic
  • func (l *QuotaTaskLogic) ProcessTask(ctx context.Context, t *asynq.Task) error
• type RateLogic
  • func NewRateLogic(svcCtx *svc.ServiceContext) *RateLogic
  • func (l *RateLogic) ProcessTask(ctx context.Context, _ *asynq.Task) error

Constants

const (
	UnitTimeNoLimit = "NoLimit" // Unlimited time subscription
	UnitTimeYear    = "Year"    // Annual subscription
	UnitTimeMonth   = "Month"   // Monthly subscription
	UnitTimeDay     = "Day"     // Daily subscription
	UnitTimeHour    = "Hour"    // Hourly subscription
	UnitTimeMinute  = "Minute"  // Per-minute subscription

)

Types

type ErrorInfo

type ErrorInfo struct {
	UserSubscribeId int64  `json:"user_subscribe_id"`
	Error           string `json:"error"`
}

type QuotaTaskLogic

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

func NewQuotaTaskLogic

func NewQuotaTaskLogic(svcCtx *svc.ServiceContext) *QuotaTaskLogic

func (*QuotaTaskLogic) ProcessTask

func (l *QuotaTaskLogic) ProcessTask(ctx context.Context, t *asynq.Task) error

type RateLogic

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

func NewRateLogic

func NewRateLogic(svcCtx *svc.ServiceContext) *RateLogic

func (*RateLogic) ProcessTask

func (l *RateLogic) ProcessTask(ctx context.Context, _ *asynq.Task) error