traffic

Documentation

Index

• type ResetTrafficLogic
  • func NewResetTrafficLogic(svc *svc.ServiceContext) *ResetTrafficLogic
  • func (l *ResetTrafficLogic) ProcessTask(ctx context.Context, _ *asynq.Task) error
• type ServerDataLogic
  • func NewServerDataLogic(svc *svc.ServiceContext) *ServerDataLogic
  • func (l *ServerDataLogic) ProcessTask(ctx context.Context, _ *asynq.Task) error
• type TrafficStatisticsLogic
  • func NewTrafficStatisticsLogic(svc *svc.ServiceContext) *TrafficStatisticsLogic
  • func (l *TrafficStatisticsLogic) ProcessTask(ctx context.Context, task *asynq.Task) error

Types

type ResetTrafficLogic

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

ResetTrafficLogic handles traffic reset logic for different subscription cycles Supports three reset modes: - reset_cycle = 1: Reset on 1st of every month - reset_cycle = 2: Reset monthly based on subscription start date - reset_cycle = 3: Reset yearly based on subscription start date

func NewResetTrafficLogic

func NewResetTrafficLogic(svc *svc.ServiceContext) *ResetTrafficLogic

func (*ResetTrafficLogic) ProcessTask

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

ProcessTask executes the traffic reset task for all subscription types with enhanced retry mechanism

type ServerDataLogic

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

func NewServerDataLogic

func NewServerDataLogic(svc *svc.ServiceContext) *ServerDataLogic

func (*ServerDataLogic) ProcessTask

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

type TrafficStatisticsLogic

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

func NewTrafficStatisticsLogic

func NewTrafficStatisticsLogic(svc *svc.ServiceContext) *TrafficStatisticsLogic

func (*TrafficStatisticsLogic) ProcessTask

func (l *TrafficStatisticsLogic) ProcessTask(ctx context.Context, task *asynq.Task) error