BaseRank

Documentation

Index

• func OverRank(args *ArgsOverRank) (err error)
• func Run()
• type ArgsAppendRank
• type ArgsGetRankList
• type ArgsGetRankOverList
• type ArgsOverRank
• type ArgsPickRank
• type FieldsRank
  • func AppendRank(args *ArgsAppendRank) (data FieldsRank, err error)
  • func GetRankList(args *ArgsGetRankList) (dataList []FieldsRank, dataCount int64, err error)
  • func PickRank(args *ArgsPickRank) (dataList []FieldsRank, err error)
• type FieldsRankOver
  • func GetRankOverList(args *ArgsGetRankOverList) (dataList []FieldsRankOver, dataCount int64, err error)

Functions

func OverRank

func OverRank(args *ArgsOverRank) (err error)

func Run

func Run()

Types

type ArgsAppendRank

type ArgsAppendRank struct {
	//服务标识码
	ServiceMark string `json:"serviceMark"`
	//过期时间
	ExpireAt time.Time `json:"expireAt"`
	//提取最短间隔 s
	PickMin int64 `json:"pickMin"`
	//任务标识码
	MissionMark string `json:"missionMark"`
	//任务内容
	MissionData []byte `json:"missionData"`
}

写入列队

type ArgsGetRankList

type ArgsGetRankList struct {
	//分页
	Pages CoreSQLPages.ArgsDataList `json:"pages"`
	//服务标识码
	ServiceMark string `json:"serviceMark"`
	//任务标识码
	MissionMark string `json:"missionMark"`
}

获取列队列表

type ArgsGetRankOverList

type ArgsGetRankOverList struct {
	//分页
	Pages CoreSQLPages.ArgsDataList `json:"pages"`
	//服务标识码
	ServiceMark string `json:"serviceMark"`
	//任务标识码
	MissionMark string `json:"missionMark"`
	//任务参数
	MissionData []byte `json:"missionData"`
}

获取完成列队

type ArgsOverRank

type ArgsOverRank struct {
	//ID
	ID int64 `json:"id"`
	//完成结果
	Result []byte `json:"result"`
}

标记完成

type ArgsPickRank

type ArgsPickRank struct {
	//服务标识码
	ServiceMark string `json:"serviceMark"`
	//任务标识码
	// 可以指定空任务标识码，可以获得该服务下所有任务
	MissionMark string `json:"missionMark"`
	//要提取几个
	Max int64 `json:"max"`
}

抽取一组数据用于计算

type FieldsRank

type FieldsRank struct {
	//ID
	ID int64 `db:"id" json:"id"`
	//创建时间
	CreateAt time.Time `db:"create_at" json:"createAt"`
	//过期时间
	ExpireAt time.Time `db:"expire_at" json:"expireAt"`
	//提取最短间隔 s
	PickMin int64 `db:"pick_min" json:"pickMin"`
	//下一次允许提取的时间
	// 会根据任务类型，做一些超时锁定，避免被连续提取
	// 此处为下一次提取的时间
	PickAt time.Time `db:"pick_at" json:"pickAt"`
	//服务来源
	ServiceMark string `db:"service_mark" json:"serviceMark"`
	//任务标识码
	MissionMark string `db:"mission_mark" json:"missionMark"`
	//任务内容
	MissionData []byte `db:"mission_data" json:"missionData"`
}

列队数据表

func AppendRank

func AppendRank(args *ArgsAppendRank) (data FieldsRank, err error)

func GetRankList

func GetRankList(args *ArgsGetRankList) (dataList []FieldsRank, dataCount int64, err error)

func PickRank

func PickRank(args *ArgsPickRank) (dataList []FieldsRank, err error)

type FieldsRankOver

type FieldsRankOver struct {
	//ID
	ID int64 `db:"id" json:"id"`
	//创建时间
	CreateAt time.Time `db:"create_at" json:"createAt"`
	//过期时间
	ExpireAt time.Time `db:"expire_at" json:"expireAt"`
	//结束时间
	OverAt time.Time `db:"over_at" json:"overAt"`
	//完成结果
	Result []byte `db:"result" json:"result"`
	//服务来源
	ServiceMark string `db:"service_mark" json:"serviceMark"`
	//任务标识码
	MissionMark string `db:"mission_mark" json:"missionMark"`
	//任务内容
	MissionData []byte `db:"mission_data" json:"missionData"`
}

任务结束列队

func GetRankOverList

func GetRankOverList(args *ArgsGetRankOverList) (dataList []FieldsRankOver, dataCount int64, err error)