service

type ALike ¶

type ALike struct {
	AsyncAction
}

Like implement IExec, async like 3 times

func (ALike) Do(user User, medal dto.MedalInfo) bool

func (ALike) Finish(user User, medal []dto.MedalInfo)

type AShare ¶

type AShare struct {
	AsyncAction
}

Share implement IExec, async share 5 times

func (AShare) Do(user User, medal dto.MedalInfo) bool

func (AShare) Finish(user User, medal []dto.MedalInfo)

type AsyncAction ¶

type AsyncAction struct{}

AsyncAction implement IConcurrency, support asynchronous actions

func (a *AsyncAction) Exec(user User, job *sync.WaitGroup, child IExec) []dto.MedalInfo

type Danmaku ¶

type Danmaku struct {
	SyncAction
}

Danmaku implement IExec, default sync, include sending daily danmu

func (Danmaku) Do(user User, medal dto.MedalInfo) bool

func (Danmaku) Finish(user User, medal []dto.MedalInfo)

type IAction ¶

type IAction interface {
	IConcurrency
	IExec
}

Action represent a single action for a single user

type IConcurrency ¶

type IConcurrency interface {
	// Exec the action of child and execute retry backup if
	Exec(user User, work *sync.WaitGroup, child IExec) []dto.MedalInfo
}

type IExec ¶

type IExec interface {
	// Do represent real action
	Do(user User, medal dto.MedalInfo) bool
	// Finish represent action complete
	Finish(user User, medal []dto.MedalInfo)
}

type Like ¶

type Like struct {
	SyncAction
}

Like implement IExec, sync like 3 times

func (Like) Do(user User, medal dto.MedalInfo) bool

func (Like) Finish(user User, medal []dto.MedalInfo)

type Share ¶

type Share struct {
	SyncAction
}

Share implement IExec, sync share 5 times

func (Share) Do(user User, medal dto.MedalInfo) bool

func (Share) Finish(user User, medal []dto.MedalInfo)

type SyncAction ¶

type SyncAction struct{}

SyncAction implement IConcurrency, support synchronous actions

func (a *SyncAction) Exec(user User, job *sync.WaitGroup, child IExec) []dto.MedalInfo

type Task ¶

type Task struct {
	User
	// contains filtered or unexported fields
}

Task aggregate user info and corresponding action

func NewTask(user User, actions []IAction) Task

func (task *Task) Start()

type User ¶

type User struct {
	// 用户ID
	Uid int
	// 用户名称
	Name string
	// contains filtered or unexported fields
}

func NewUser(accessKey, pushName string, allowUIDs, banUIDs []int) User

func (user *User) Init() bool

func (user *User) RunOnce() bool

func (user *User) Start(wg *sync.WaitGroup)

type WatchLive ¶

type WatchLive struct {
	AsyncAction
}

WatchLive implement IExec, default async, include sending heartbeat

func (WatchLive) Do(user User, medal dto.MedalInfo) bool

func (WatchLive) Finish(user User, medal []dto.MedalInfo)