traffic

type Dependencies ¶ added in v1.19.0

type Dependencies struct {
	Store      repository.Store
	Redis      *redis.Client
	Queue      *asynqx.Client
	Log        func() config.Log
	Aggregator trafficagg.Deps
}

type FlushTrafficLogic ¶ added in v1.3.15

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

func NewFlushTrafficLogic(deps Dependencies) *FlushTrafficLogic

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

type LogCleanupLogic ¶ added in v1.19.0

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

LogCleanupLogic owns retention independently from traffic aggregation so a failed statistics run cannot silently disable log cleanup (or vice versa).

func NewLogCleanupLogic(store cleanupStore, logConfig func() config.Log) *LogCleanupLogic

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

type ResetTrafficLogic ¶ added in v1.0.3

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(deps Dependencies) *ResetTrafficLogic

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

type ServerDataLogic ¶

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

func NewServerDataLogic(deps Dependencies) *ServerDataLogic

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

type StatLogic ¶ added in v1.1.0

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

func NewStatLogic(deps Dependencies) *StatLogic

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

type TrafficStatisticsLogic ¶

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

func NewTrafficStatisticsLogic(deps Dependencies) *TrafficStatisticsLogic

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