ClassQueue

Documentation

Index

• type ArgsAppend
• type ArgsDelete
• type ArgsGetByID
• type ArgsGetByModID
• type ArgsGetList
• type ArgsUpdateStatus
• type FieldsQueue
• type Queue
  • func (t *Queue) Append(args *ArgsAppend) (err error)
  • func (t *Queue) Delete(args *ArgsDelete) (err error)
  • func (t *Queue) GetByID(args *ArgsGetByID) (data FieldsQueue, err error)
  • func (t *Queue) GetByModID(args *ArgsGetByModID) (data FieldsQueue, err error)
  • func (t *Queue) GetList(args *ArgsGetList) (dataList []FieldsQueue, dataCount int64, err error)
  • func (t *Queue) Init(tagTableName string)
  • func (t *Queue) Pick() (data FieldsQueue, err error)
  • func (t *Queue) UpdateStatus(args *ArgsUpdateStatus) (err error)

Types

type ArgsAppend

type ArgsAppend struct {
	//其他模块的ID
	ModID int64 `db:"mod_id" json:"modID"`
	//处理状态
	// 如果消息件存在多个状态，可使用，否则应及时删除该消息
	Status int `db:"status" json:"status"`
	//扩展参数
	Params CoreSQLConfig.FieldsConfigsType `db:"params" json:"params"`
}

ArgsAppend 写入数据参数

type ArgsDelete

type ArgsDelete struct {
	//ID
	ID int64 `db:"id" json:"id" check:"id"`
}

ArgsDelete 删除数据参数

type ArgsGetByID

type ArgsGetByID struct {
	//ID
	ID int64 `db:"id" json:"id" check:"id"`
}

ArgsGetByID 获取ID参数

type ArgsGetByModID

type ArgsGetByModID struct {
	//Mod ID
	ModID int64 `db:"mod_id" json:"modID" check:"id"`
}

ArgsGetByModID 通过绑定ID获取参数

type ArgsGetList

type ArgsGetList struct {
	//分页
	Pages CoreSQLPages.ArgsDataList `json:"pages"`
	//处理状态
	// 如果消息件存在多个状态，可使用，否则应及时删除该消息
	Status int `db:"status" json:"status" check:"than0Int" empty:"true"`
}

ArgsGetList 获取列表参数

type ArgsUpdateStatus

type ArgsUpdateStatus struct {
	//ID
	ID int64 `db:"id" json:"id" check:"id"`
	//处理状态
	// 如果消息件存在多个状态，可使用，否则应及时删除该消息
	Status int `db:"status" json:"status"`
}

ArgsUpdateStatus 修改status参数

type FieldsQueue

type FieldsQueue struct {
	//ID
	ID int64 `db:"id" json:"id"`
	//创建时间
	CreateAt time.Time `db:"create_at" json:"createAt"`
	//更新时间
	UpdateAt time.Time `db:"update_at" json:"updateAt"`
	//其他模块的ID
	ModID int64 `db:"mod_id" json:"modID"`
	//处理状态
	// 如果消息件存在多个状态，可使用，否则应及时删除该消息
	Status int `db:"status" json:"status"`
	//扩展参数
	Params CoreSQLConfig.FieldsConfigsType `db:"params" json:"params"`
}

type Queue

type Queue struct {
	//主表
	TableName string
	//清理多久的数据？
	ClearDay int
}

func (*Queue) Append

func (t *Queue) Append(args *ArgsAppend) (err error)

Append 写入数据

func (*Queue) Delete

func (t *Queue) Delete(args *ArgsDelete) (err error)

Delete 删除数据

func (*Queue) GetByID

func (t *Queue) GetByID(args *ArgsGetByID) (data FieldsQueue, err error)

GetByID 获取ID

func (*Queue) GetByModID

func (t *Queue) GetByModID(args *ArgsGetByModID) (data FieldsQueue, err error)

GetByModID 通过绑定ID获取

func (*Queue) GetList

func (t *Queue) GetList(args *ArgsGetList) (dataList []FieldsQueue, dataCount int64, err error)

GetList 获取列表

func (*Queue) Init

func (t *Queue) Init(tagTableName string)

Init 初始化对象

func (*Queue) Pick

func (t *Queue) Pick() (data FieldsQueue, err error)

Pick 提取数据 自动按照最早提取原则提取数据 提取等同销毁处理

func (*Queue) UpdateStatus

func (t *Queue) UpdateStatus(args *ArgsUpdateStatus) (err error)

UpdateStatus 修改status