task

type QuotaTaskLogic ¶

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

QuotaTaskLogic is the queue shell for the admin-scheduled quota grants; the business logic lives in the subscription module (ADR-001 step 6 preparation).

func NewQuotaTaskLogic(svcCtx *svc.ServiceContext) *QuotaTaskLogic

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

type RateLogic ¶ added in v1.1.8

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

func NewRateLogic(svcCtx *svc.ServiceContext) *RateLogic

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